Reduced ServerManager size

1 files changed, 0 insertions, 879 deletions

diff --git a/src/org/traccar/Server.java b/src/org/traccar/Server.java
deleted file mode 100644
index e1d9efa3d..000000000
--- a/src/org/traccar/Server.java
+++ /dev/null
@@ -1,879 +0,0 @@
-/*
- * Copyright 2012 Anton Tananaev (anton.tananaev@gmail.com)
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.traccar;
-
-import java.io.FileInputStream;
-import java.io.IOException;
-import java.nio.ByteOrder;
-import java.sql.SQLException;
-import java.text.DateFormat;
-import java.text.FieldPosition;
-import java.text.SimpleDateFormat;
-import java.util.Date;
-import java.util.LinkedList;
-import java.util.List;
-import java.util.Properties;
-import java.util.logging.FileHandler;
-import java.util.logging.Formatter;
-import java.util.logging.LogRecord;
-import org.jboss.netty.bootstrap.ServerBootstrap;
-import org.jboss.netty.buffer.ChannelBuffers;
-import org.jboss.netty.channel.ChannelPipeline;
-import org.jboss.netty.handler.codec.frame.DelimiterBasedFrameDecoder;
-import org.jboss.netty.handler.codec.frame.LengthFieldBasedFrameDecoder;
-import org.jboss.netty.handler.codec.string.StringDecoder;
-import org.jboss.netty.handler.codec.string.StringEncoder;
-import org.traccar.geocode.GoogleReverseGeocoder;
-import org.traccar.geocode.ReverseGeocoder;
-import org.traccar.helper.Log;
-import org.traccar.http.WebServer;
-import org.traccar.model.DataManager;
-import org.traccar.model.DatabaseDataManager;
-import org.traccar.protocol.*;
-
-/**
- * Server
- */
-public class Server {
-
-    /**
-     * Server list
-     */
-    private List<TrackerServer> serverList;
-
-    private boolean loggerEnabled;
-
-    public Server() {
-        serverList = new LinkedList<TrackerServer>();
-        loggerEnabled = false;
-    }
-
-    public boolean isLoggerEnabled() {
-        return loggerEnabled;
-    }
-
-    private DataManager dataManager;
-
-    private WebServer webServer;
-
-    private ReverseGeocoder geocoder;
-
-    /**
-     * Initialize
-     */
-    public void init(String[] arguments)
-            throws IOException, ClassNotFoundException, SQLException {
-
-        // Load properties
-        Properties properties = new Properties();
-        if (arguments.length > 0) {
-            properties.loadFromXML(new FileInputStream(arguments[0]));
-        }
-
-        dataManager = new DatabaseDataManager(properties);
-
-        initLogger(properties);
-        initGeocoder(properties);
-
-        initXexunServer(properties);
-        initGps103Server(properties);
-        initTk103Server(properties);
-        initGl100Server(properties);
-        initGl200Server(properties);
-        initT55Server(properties);
-        initXexun2Server(properties);
-        initAvl08Server(properties);
-        initEnforaServer(properties);
-        initMeiligaoServer(properties);
-        initMaxonServer(properties);
-        initST210Server(properties);
-        initProgressServer(properties);
-        initH02Server(properties);
-        initJt600Server(properties);
-        initEv603Server(properties);
-        initV680Server(properties);
-        initPt502Server(properties);
-        initTr20Server(properties);
-        initNavisServer(properties);
-        initMeitrackServer(properties);
-        initSkypatrolServer(properties);
-        initGt02Server(properties);
-        initGt06Server(properties);
-
-        // Initialize web server
-        if (Boolean.valueOf(properties.getProperty("http.enable"))) {
-            webServer = new WebServer(properties);
-        }
-    }
-
-    /**
-     * Start
-     */
-    public void start() {
-        if (webServer != null) {
-            webServer.start();
-        }
-        for (Object server: serverList) {
-            ((TrackerServer) server).start();
-        }
-    }
-
-    /**
-     * Stop
-     */
-    public void stop() {
-        for (Object server: serverList) {
-            ((TrackerServer) server).stop();
-        }
-
-        // Release resources
-        GlobalChannelFactory.release();
-        GlobalTimer.release();
-
-        if (webServer != null) {
-            webServer.stop();
-        }
-    }
-
-    /**
-     * Destroy
-     */
-    public void destroy() {
-        serverList.clear();
-    }
-
-    /**
-     * Initialize logger
-     */
-    private void initLogger(Properties properties) throws IOException {
-
-        loggerEnabled = Boolean.valueOf(properties.getProperty("logger.enable"));
-
-        if (loggerEnabled) {
-
-            String fileName = properties.getProperty("logger.file");
-            if (fileName != null) {
-
-                FileHandler file = new FileHandler(fileName, true);
-
-                // Simple formatter
-                file.setFormatter(new Formatter() {
-                    private final String LINE_SEPARATOR =
-                            System.getProperty("line.separator", "\n");
-
-                    private final DateFormat dateFormat =
-                            new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
-
-                    public String format(LogRecord record) {
-                        StringBuffer line = new StringBuffer();
-                        dateFormat.format(new Date(record.getMillis()), line, new FieldPosition(0));
-                        line.append(" ");
-                        line.append(record.getSourceClassName());
-                        line.append(".");
-                        line.append(record.getSourceMethodName());
-                        line.append(" ");
-                        line.append(record.getLevel().getName());
-                        line.append(": ");
-                        line.append(formatMessage(record));
-                        line.append(LINE_SEPARATOR);
-                        return line.toString();
-                    }
-                });
-
-                Log.getLogger().addHandler(file);
-            }
-        }
-    }
-
-    private void initGeocoder(Properties properties) throws IOException {
-        if (Boolean.parseBoolean(properties.getProperty("geocoder.enable"))) {
-            geocoder = new GoogleReverseGeocoder();
-        }
-    }
-
-    private boolean isProtocolEnabled(Properties properties, String protocol) {
-        String enabled = properties.getProperty(protocol + ".enable");
-        if (enabled != null) {
-            return Boolean.valueOf(enabled);
-        }
-        return false;
-    }
-
-    private String getProtocolInterface(Properties properties, String protocol) {
-        return properties.getProperty(protocol + ".address");
-    }
-
-    private Integer getProtocolPort(Properties properties, String protocol) {
-        String port = properties.getProperty(protocol + ".port");
-        if (port != null) {
-            return Integer.valueOf(port);
-        }
-        return 5000; // Magic number
-    }
-
-    private Integer getProtocolResetDelay(Properties properties, String protocol) {
-        String resetDelay = properties.getProperty(protocol + ".resetDelay");
-        if (resetDelay != null) {
-            return Integer.valueOf(resetDelay);
-        }
-        return 0;
-    }
-
-    /**
-     * Init Xexun server
-     */
-    private void initXexunServer(Properties properties) throws SQLException {
-
-        String protocol = "xexun";
-        if (isProtocolEnabled(properties, protocol)) {
-
-            TrackerServer server = new TrackerServer(new ServerBootstrap());
-            server.setPort(getProtocolPort(properties, protocol));
-            server.setAddress(getProtocolInterface(properties, protocol));
-            final Integer resetDelay = getProtocolResetDelay(properties, protocol);
-
-            server.setPipelineFactory(new GenericPipelineFactory(server, dataManager, isLoggerEnabled(), resetDelay, geocoder) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new XexunFrameDecoder());
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("objectDecoder", new XexunProtocolDecoder(getDataManager()));
-                }
-            });
-
-            serverList.add(server);
-        }
-    }
-
-    /**
-     * Init Gps103 server
-     */
-    private void initGps103Server(Properties properties) throws SQLException {
-
-        String protocol = "gps103";
-        if (isProtocolEnabled(properties, protocol)) {
-
-            TrackerServer server = new TrackerServer(new ServerBootstrap());
-            server.setPort(getProtocolPort(properties, protocol));
-            server.setAddress(getProtocolInterface(properties, protocol));
-            final Integer resetDelay = getProtocolResetDelay(properties, protocol);
-
-            server.setPipelineFactory(new GenericPipelineFactory(server, dataManager, isLoggerEnabled(), resetDelay, geocoder) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    byte delimiter[] = { (byte) ';' };
-                    pipeline.addLast("frameDecoder",
-                            new DelimiterBasedFrameDecoder(1024, ChannelBuffers.wrappedBuffer(delimiter)));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("stringEncoder", new StringEncoder());
-                    pipeline.addLast("objectDecoder", new Gps103ProtocolDecoder(getDataManager()));
-                }
-            });
-
-            serverList.add(server);
-        }
-    }
-
-    /**
-     * Init Tk103 server
-     */
-    private void initTk103Server(Properties properties) throws SQLException {
-
-        String protocol = "tk103";
-        if (isProtocolEnabled(properties, protocol)) {
-
-            TrackerServer server = new TrackerServer(new ServerBootstrap());
-            server.setPort(getProtocolPort(properties, protocol));
-            server.setAddress(getProtocolInterface(properties, protocol));
-            final Integer resetDelay = getProtocolResetDelay(properties, protocol);
-
-            server.setPipelineFactory(new GenericPipelineFactory(server, dataManager, isLoggerEnabled(), resetDelay, geocoder) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    byte delimiter[] = { (byte) ')' };
-                    pipeline.addLast("frameDecoder",
-                            new DelimiterBasedFrameDecoder(1024, ChannelBuffers.wrappedBuffer(delimiter)));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("stringEncoder", new StringEncoder());
-                    pipeline.addLast("objectDecoder", new Tk103ProtocolDecoder(getDataManager()));
-                }
-            });
-
-            serverList.add(server);
-        }
-    }
-
-    /**
-     * Init Gl100 server
-     */
-    private void initGl100Server(Properties properties) throws SQLException {
-
-        String protocol = "gl100";
-        if (isProtocolEnabled(properties, protocol)) {
-
-            TrackerServer server = new TrackerServer(new ServerBootstrap());
-            server.setPort(getProtocolPort(properties, protocol));
-            server.setAddress(getProtocolInterface(properties, protocol));
-            final Integer resetDelay = getProtocolResetDelay(properties, protocol);
-
-            server.setPipelineFactory(new GenericPipelineFactory(server, dataManager, isLoggerEnabled(), resetDelay, geocoder) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    byte delimiter[] = { (byte) 0x0 };
-                    pipeline.addLast("frameDecoder",
-                            new DelimiterBasedFrameDecoder(1024, ChannelBuffers.wrappedBuffer(delimiter)));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("stringEncoder", new StringEncoder());
-                    pipeline.addLast("objectDecoder", new Gl100ProtocolDecoder(getDataManager()));
-                }
-            });
-
-            serverList.add(server);
-        }
-    }
-
-    /**
-     * Init Gl200 server
-     */
-    private void initGl200Server(Properties properties) throws SQLException {
-
-        String protocol = "gl200";
-        if (isProtocolEnabled(properties, protocol)) {
-
-            TrackerServer server = new TrackerServer(new ServerBootstrap());
-            server.setPort(getProtocolPort(properties, protocol));
-            server.setAddress(getProtocolInterface(properties, protocol));
-            final Integer resetDelay = getProtocolResetDelay(properties, protocol);
-
-            server.setPipelineFactory(new GenericPipelineFactory(server, dataManager, isLoggerEnabled(), resetDelay, geocoder) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    byte delimiter[] = { (byte) '$' };
-                    pipeline.addLast("frameDecoder",
-                            new DelimiterBasedFrameDecoder(1024, ChannelBuffers.wrappedBuffer(delimiter)));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("stringEncoder", new StringEncoder());
-                    pipeline.addLast("objectDecoder", new Gl200ProtocolDecoder(getDataManager()));
-                }
-            });
-
-            serverList.add(server);
-        }
-    }
-
-    /**
-     * Init T55 server
-     */
-    private void initT55Server(Properties properties) throws SQLException {
-
-        String protocol = "t55";
-        if (isProtocolEnabled(properties, protocol)) {
-
-            TrackerServer server = new TrackerServer(new ServerBootstrap());
-            server.setPort(getProtocolPort(properties, protocol));
-            server.setAddress(getProtocolInterface(properties, protocol));
-            final Integer resetDelay = getProtocolResetDelay(properties, protocol);
-
-            server.setPipelineFactory(new GenericPipelineFactory(server, dataManager, isLoggerEnabled(), resetDelay, geocoder) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    byte delimiter[] = { (byte) '\r', (byte) '\n' };
-                    pipeline.addLast("frameDecoder",
-                            new DelimiterBasedFrameDecoder(1024, ChannelBuffers.wrappedBuffer(delimiter)));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("stringEncoder", new StringEncoder());
-                    pipeline.addLast("objectDecoder", new T55ProtocolDecoder(getDataManager()));
-                }
-            });
-
-            serverList.add(server);
-        }
-    }
-
-    /**
-     * Init Xexun 2 server
-     */
-    private void initXexun2Server(Properties properties) throws SQLException {
-
-        String protocol = "xexun2";
-        if (isProtocolEnabled(properties, protocol)) {
-
-            TrackerServer server = new TrackerServer(new ServerBootstrap());
-            server.setPort(getProtocolPort(properties, protocol));
-            server.setAddress(getProtocolInterface(properties, protocol));
-            final Integer resetDelay = getProtocolResetDelay(properties, protocol);
-
-            server.setPipelineFactory(new GenericPipelineFactory(server, dataManager, isLoggerEnabled(), resetDelay, geocoder) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    byte delimiter[] = { (byte) '\n' }; // tracker bug \n\r
-                    pipeline.addLast("frameDecoder",
-                            new DelimiterBasedFrameDecoder(1024, ChannelBuffers.wrappedBuffer(delimiter)));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("objectDecoder", new Xexun2ProtocolDecoder(getDataManager()));
-                }
-            });
-
-            serverList.add(server);
-        }
-    }
-
-    /**
-     * Init AVL-08 server
-     */
-    private void initAvl08Server(Properties properties) throws SQLException {
-
-        String protocol = "avl08";
-        if (isProtocolEnabled(properties, protocol)) {
-
-            TrackerServer server = new TrackerServer(new ServerBootstrap());
-            server.setPort(getProtocolPort(properties, protocol));
-            server.setAddress(getProtocolInterface(properties, protocol));
-            final Integer resetDelay = getProtocolResetDelay(properties, protocol);
-
-            server.setPipelineFactory(new GenericPipelineFactory(server, dataManager, isLoggerEnabled(), resetDelay, geocoder) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    byte delimiter[] = { (byte) '\r', (byte) '\n' };
-                    pipeline.addLast("frameDecoder",
-                            new DelimiterBasedFrameDecoder(1024, ChannelBuffers.wrappedBuffer(delimiter)));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("objectDecoder", new Avl08ProtocolDecoder(getDataManager()));
-                }
-            });
-
-            serverList.add(server);
-        }
-    }
-
-    /**
-     * Init Enfora server
-     */
-    private void initEnforaServer(Properties properties) throws SQLException {
-
-        String protocol = "enfora";
-        if (isProtocolEnabled(properties, protocol)) {
-
-            TrackerServer server = new TrackerServer(new ServerBootstrap());
-            server.setPort(getProtocolPort(properties, protocol));
-            server.setAddress(getProtocolInterface(properties, protocol));
-            final Integer resetDelay = getProtocolResetDelay(properties, protocol);
-
-            server.setPipelineFactory(new GenericPipelineFactory(server, dataManager, isLoggerEnabled(), resetDelay, geocoder) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new LengthFieldBasedFrameDecoder(1024, 0, 2, -2, 2));
-                    pipeline.addLast("objectDecoder", new EnforaProtocolDecoder(getDataManager()));
-                }
-            });
-
-            serverList.add(server);
-        }
-    }
-
-    /**
-     * Init Meiligao server
-     */
-    private void initMeiligaoServer(Properties properties) throws SQLException {
-
-        String protocol = "meiligao";
-        if (isProtocolEnabled(properties, protocol)) {
-
-            TrackerServer server = new TrackerServer(new ServerBootstrap());
-            server.setPort(getProtocolPort(properties, protocol));
-            server.setAddress(getProtocolInterface(properties, protocol));
-            final Integer resetDelay = getProtocolResetDelay(properties, protocol);
-
-            server.setPipelineFactory(new GenericPipelineFactory(server, dataManager, isLoggerEnabled(), resetDelay, geocoder) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new LengthFieldBasedFrameDecoder(1024, 2, 2, -4, 4));
-                    pipeline.addLast("objectDecoder", new MeiligaoProtocolDecoder(getDataManager()));
-                }
-            });
-
-            serverList.add(server);
-        }
-    }
-
-    private void initMaxonServer(Properties properties) throws SQLException {
-        String protocol = "maxon";
-        if (isProtocolEnabled(properties, protocol)) {
-
-            TrackerServer server = new TrackerServer(new ServerBootstrap());
-            server.setPort(getProtocolPort(properties, protocol));
-            server.setAddress(getProtocolInterface(properties, protocol));
-            final Integer resetDelay = getProtocolResetDelay(properties, protocol);
-
-            server.setPipelineFactory(new GenericPipelineFactory(server, dataManager, isLoggerEnabled(), resetDelay, geocoder) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    byte delimiter[] = { (byte) '\r', (byte) '\n' };
-                    pipeline.addLast("frameDecoder",
-                            new DelimiterBasedFrameDecoder(1024, ChannelBuffers.wrappedBuffer(delimiter)));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("stringEncoder", new StringEncoder());
-                    pipeline.addLast("objectDecoder", new MaxonProtocolDecoder(getDataManager()));
-                }
-            });
-
-            serverList.add(server);
-        }
-    }
-
-    private void initST210Server(Properties properties) throws SQLException {
-        String protocol = "st210";
-        if (isProtocolEnabled(properties, protocol)) {
-
-            TrackerServer server = new TrackerServer(new ServerBootstrap());
-            server.setPort(getProtocolPort(properties, protocol));
-            server.setAddress(getProtocolInterface(properties, protocol));
-            final Integer resetDelay = getProtocolResetDelay(properties, protocol);
-
-            server.setPipelineFactory(new GenericPipelineFactory(server, dataManager, isLoggerEnabled(), resetDelay, geocoder) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    byte delimiter[] = { (byte) '\r' };
-                    pipeline.addLast("frameDecoder",
-                            new DelimiterBasedFrameDecoder(1024, ChannelBuffers.wrappedBuffer(delimiter)));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("objectDecoder", new ST210ProtocolDecoder(getDataManager()));
-                }
-            });
-
-            serverList.add(server);
-        }
-    }
-
-    private void initProgressServer(Properties properties) throws SQLException {
-        String protocol = "progress";
-        if (isProtocolEnabled(properties, protocol)) {
-
-            TrackerServer server = new TrackerServer(new ServerBootstrap());
-            server.setPort(getProtocolPort(properties, protocol));
-            server.setAddress(getProtocolInterface(properties, protocol));
-            server.setEndianness(ByteOrder.LITTLE_ENDIAN);
-            final Integer resetDelay = getProtocolResetDelay(properties, protocol);
-
-            server.setPipelineFactory(new GenericPipelineFactory(server, dataManager, isLoggerEnabled(), resetDelay, geocoder) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new LengthFieldBasedFrameDecoder(1024, 2, 2, 0, 0));
-                    pipeline.addLast("objectDecoder", new ProgressProtocolDecoder(getDataManager()));
-                }
-            });
-
-            serverList.add(server);
-        }
-    }
-
-    /**
-     * Init H02 server
-     */
-    private void initH02Server(Properties properties) throws SQLException {
-
-        String protocol = "h02";
-        if (isProtocolEnabled(properties, protocol)) {
-
-            TrackerServer server = new TrackerServer(new ServerBootstrap());
-            server.setPort(getProtocolPort(properties, protocol));
-            server.setAddress(getProtocolInterface(properties, protocol));
-            final Integer resetDelay = getProtocolResetDelay(properties, protocol);
-
-            server.setPipelineFactory(new GenericPipelineFactory(server, dataManager, isLoggerEnabled(), resetDelay, geocoder) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    byte delimiter[] = { (byte) '#' };
-                    pipeline.addLast("frameDecoder",
-                            new DelimiterBasedFrameDecoder(1024, ChannelBuffers.wrappedBuffer(delimiter)));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("objectDecoder", new H02ProtocolDecoder(getDataManager()));
-                }
-            });
-
-            serverList.add(server);
-        }
-    }
-
-    /**
-     * Init JT600 server
-     */
-    private void initJt600Server(Properties properties) throws SQLException {
-
-        String protocol = "jt600";
-        if (isProtocolEnabled(properties, protocol)) {
-
-            TrackerServer server = new TrackerServer(new ServerBootstrap());
-            server.setPort(getProtocolPort(properties, protocol));
-            server.setAddress(getProtocolInterface(properties, protocol));
-            final Integer resetDelay = getProtocolResetDelay(properties, protocol);
-
-            server.setPipelineFactory(new GenericPipelineFactory(server, dataManager, isLoggerEnabled(), resetDelay, geocoder) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new Jt600FrameDecoder());
-                    pipeline.addLast("objectDecoder", new Jt600ProtocolDecoder(getDataManager()));
-                }
-            });
-
-            serverList.add(server);
-        }
-    }
-
-    /**
-     * Init EV603 server
-     */
-    private void initEv603Server(Properties properties) throws SQLException {
-
-        String protocol = "ev603";
-        if (isProtocolEnabled(properties, protocol)) {
-
-            TrackerServer server = new TrackerServer(new ServerBootstrap());
-            server.setPort(getProtocolPort(properties, protocol));
-            server.setAddress(getProtocolInterface(properties, protocol));
-            final Integer resetDelay = getProtocolResetDelay(properties, protocol);
-
-            server.setPipelineFactory(new GenericPipelineFactory(server, dataManager, isLoggerEnabled(), resetDelay, geocoder) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    byte delimiter[] = { (byte) ';' };
-                    pipeline.addLast("frameDecoder",
-                            new DelimiterBasedFrameDecoder(1024, ChannelBuffers.wrappedBuffer(delimiter)));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("objectDecoder", new Ev603ProtocolDecoder(getDataManager()));
-                }
-            });
-
-            serverList.add(server);
-        }
-    }
-
-    /**
-     * Init V680 server
-     */
-    private void initV680Server(Properties properties) throws SQLException {
-
-        String protocol = "v680";
-        if (isProtocolEnabled(properties, protocol)) {
-
-            TrackerServer server = new TrackerServer(new ServerBootstrap());
-            server.setPort(getProtocolPort(properties, protocol));
-            server.setAddress(getProtocolInterface(properties, protocol));
-            final Integer resetDelay = getProtocolResetDelay(properties, protocol);
-
-            server.setPipelineFactory(new GenericPipelineFactory(server, dataManager, isLoggerEnabled(), resetDelay, geocoder) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    byte delimiter[] = { (byte) '#', (byte) '#' };
-                    pipeline.addLast("frameDecoder",
-                            new DelimiterBasedFrameDecoder(1024, ChannelBuffers.wrappedBuffer(delimiter)));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("objectDecoder", new V680ProtocolDecoder(getDataManager()));
-                }
-            });
-
-            serverList.add(server);
-        }
-    }
-
-    /**
-     * Init PT502 server
-     */
-    private void initPt502Server(Properties properties) throws SQLException {
-
-        String protocol = "pt502";
-        if (isProtocolEnabled(properties, protocol)) {
-
-            TrackerServer server = new TrackerServer(new ServerBootstrap());
-            server.setPort(getProtocolPort(properties, protocol));
-            server.setAddress(getProtocolInterface(properties, protocol));
-            final Integer resetDelay = getProtocolResetDelay(properties, protocol);
-
-            server.setPipelineFactory(new GenericPipelineFactory(server, dataManager, isLoggerEnabled(), resetDelay, geocoder) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    byte delimiter[] = { (byte) '\r', (byte) '\n' };
-                    pipeline.addLast("frameDecoder",
-                            new DelimiterBasedFrameDecoder(1024, ChannelBuffers.wrappedBuffer(delimiter)));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("stringEncoder", new StringEncoder());
-                    pipeline.addLast("objectDecoder", new Pt502ProtocolDecoder(getDataManager()));
-                }
-            });
-
-            serverList.add(server);
-        }
-    }
-
-    /**
-     * Init TR20 server
-     */
-    private void initTr20Server(Properties properties) throws SQLException {
-
-        String protocol = "tr20";
-        if (isProtocolEnabled(properties, protocol)) {
-
-            TrackerServer server = new TrackerServer(new ServerBootstrap());
-            server.setPort(getProtocolPort(properties, protocol));
-            server.setAddress(getProtocolInterface(properties, protocol));
-            final Integer resetDelay = getProtocolResetDelay(properties, protocol);
-
-            server.setPipelineFactory(new GenericPipelineFactory(server, dataManager, isLoggerEnabled(), resetDelay, geocoder) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    byte delimiter[] = { (byte) '\r', (byte) '\n' };
-                    pipeline.addLast("frameDecoder",
-                            new DelimiterBasedFrameDecoder(1024, ChannelBuffers.wrappedBuffer(delimiter)));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("stringEncoder", new StringEncoder());
-                    pipeline.addLast("objectDecoder", new Tr20ProtocolDecoder(getDataManager()));
-                }
-            });
-
-            serverList.add(server);
-        }
-    }
-
-    /**
-     * Init Navis server
-     */
-    private void initNavisServer(Properties properties) throws SQLException {
-
-        String protocol = "navis";
-        if (isProtocolEnabled(properties, protocol)) {
-
-            TrackerServer server = new TrackerServer(new ServerBootstrap());
-            server.setPort(getProtocolPort(properties, protocol));
-            server.setAddress(getProtocolInterface(properties, protocol));
-            server.setEndianness(ByteOrder.LITTLE_ENDIAN);
-            final Integer resetDelay = getProtocolResetDelay(properties, protocol);
-
-            server.setPipelineFactory(new GenericPipelineFactory(server, dataManager, isLoggerEnabled(), resetDelay, geocoder) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new LengthFieldBasedFrameDecoder(4 * 1024, 12, 2, 2, 0));
-                    pipeline.addLast("objectDecoder", new NavisProtocolDecoder(getDataManager()));
-                }
-            });
-
-            serverList.add(server);
-        }
-    }
-
-    /**
-     * Init Meitrack server
-     */
-    private void initMeitrackServer(Properties properties) throws SQLException {
-
-        String protocol = "meitrack";
-        if (isProtocolEnabled(properties, protocol)) {
-
-            TrackerServer server = new TrackerServer(new ServerBootstrap());
-            server.setPort(getProtocolPort(properties, protocol));
-            server.setAddress(getProtocolInterface(properties, protocol));
-            final Integer resetDelay = getProtocolResetDelay(properties, protocol);
-
-            server.setPipelineFactory(new GenericPipelineFactory(server, dataManager, isLoggerEnabled(), resetDelay, geocoder) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    byte delimiter[] = { (byte) '\r', (byte) '\n' };
-                    pipeline.addLast("frameDecoder",
-                            new DelimiterBasedFrameDecoder(1024, ChannelBuffers.wrappedBuffer(delimiter)));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("stringEncoder", new StringEncoder());
-                    pipeline.addLast("objectDecoder", new MeitrackProtocolDecoder(getDataManager()));
-                }
-            });
-
-            serverList.add(server);
-        }
-    }
-
-    /**
-     * Init SkyPatrol server
-     */
-    private void initSkypatrolServer(Properties properties) throws SQLException {
-
-        String protocol = "skypatrol";
-        if (isProtocolEnabled(properties, protocol)) {
-
-            TrackerServer server = new TrackerServer(new ServerBootstrap());
-            server.setPort(getProtocolPort(properties, protocol));
-            server.setAddress(getProtocolInterface(properties, protocol));
-            final Integer resetDelay = getProtocolResetDelay(properties, protocol);
-
-            server.setPipelineFactory(new GenericPipelineFactory(server, dataManager, isLoggerEnabled(), resetDelay, geocoder) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("objectDecoder", new SkypatrolProtocolDecoder(getDataManager()));
-                }
-            });
-
-            serverList.add(server);
-        }
-    }
-
-    /**
-     * Init GT02 server
-     */
-    private void initGt02Server(Properties properties) throws SQLException {
-
-        String protocol = "gt02";
-        if (isProtocolEnabled(properties, protocol)) {
-
-            TrackerServer server = new TrackerServer(new ServerBootstrap());
-            server.setPort(getProtocolPort(properties, protocol));
-            server.setAddress(getProtocolInterface(properties, protocol));
-            final Integer resetDelay = getProtocolResetDelay(properties, protocol);
-
-            server.setPipelineFactory(new GenericPipelineFactory(server, dataManager, isLoggerEnabled(), resetDelay, geocoder) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new LengthFieldBasedFrameDecoder(256, 2, 1, 2, 0));
-                    pipeline.addLast("objectDecoder", new Gt02ProtocolDecoder(getDataManager()));
-                }
-            });
-
-            serverList.add(server);
-        }
-    }
-
-    /**
-     * Init GT06 server
-     */
-    private void initGt06Server(Properties properties) throws SQLException {
-
-        String protocol = "gt06";
-        if (isProtocolEnabled(properties, protocol)) {
-
-            TrackerServer server = new TrackerServer(new ServerBootstrap());
-            server.setPort(getProtocolPort(properties, protocol));
-            server.setAddress(getProtocolInterface(properties, protocol));
-            final Integer resetDelay = getProtocolResetDelay(properties, protocol);
-
-            server.setPipelineFactory(new GenericPipelineFactory(server, dataManager, isLoggerEnabled(), resetDelay, geocoder) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new LengthFieldBasedFrameDecoder(256, 2, 1, 2, 0));
-                    pipeline.addLast("objectDecoder", new Gt06ProtocolDecoder(getDataManager()));
-                }
-            });
-
-            serverList.add(server);
-        }
-    }
-
-}