Merge commands implmentation (fix #1271)

1 files changed, 90 insertions, 1286 deletions

diff --git a/src/org/traccar/ServerManager.java b/src/org/traccar/ServerManager.java
index 3ad7cb474..bf6e87e17 100644
--- a/src/org/traccar/ServerManager.java
+++ b/src/org/traccar/ServerManager.java
@@ -32,100 +32,99 @@ import org.jboss.netty.handler.codec.string.StringDecoder;
 import org.jboss.netty.handler.codec.string.StringEncoder;
 import org.traccar.protocol.*;
 
-
 public class ServerManager {
 
     private final List<TrackerServer> serverList = new LinkedList<TrackerServer>();
 
     public void init() throws Exception {
 
-        initGps103Server("gps103");
-        initTk103Server("tk103");
-        initGl100Server("gl100");
-        initGl200Server("gl200");
-        initT55Server("t55");
-        initXexunServer("xexun");
-        initTotemServer("totem");
-        initEnforaServer("enfora");
-        initMeiligaoServer("meiligao");
-        initMaxonServer("maxon");
-        initSuntechServer("suntech");
-        initProgressServer("progress");
-        initH02Server("h02");
-        initJt600Server("jt600");
-        initEv603Server("ev603");
-        initV680Server("v680");
-        initPt502Server("pt502");
-        initTr20Server("tr20");
-        initNavisServer("navis");
-        initMeitrackServer("meitrack");
-        initSkypatrolServer("skypatrol");
-        initGt02Server("gt02");
-        initGt06Server("gt06");
-        initMegastekServer("megastek");
-        initNavigilServer("navigil");
-        initGpsGateServer("gpsgate");
-        initTeltonikaServer("teltonika");
-        initMta6Server("mta6");
-        initMta6CanServer("mta6can");
-        initTlt2hServer("tlt2h");
-        initSyrusServer("syrus");
-        initWondexServer("wondex");
-        initCellocatorServer("cellocator");
-        initGalileoServer("galileo");
-        initYwtServer("ywt");
-        initTk102Server("tk102");
-        initIntellitracServer("intellitrac");
-        initXt7Server("xt7");
-        initWialonServer("wialon");
-        initCarscopServer("carscop");
-        initApelServer("apel");
-        initManPowerServer("manpower");
-        initGlobalSatServer("globalsat");
-        initAtrackServer("atrack");
-        initPt3000Server("pt3000");
-        initRuptelaServer("ruptela");
-        initTopflytechServer("topflytech");
-        initLaipacServer("laipac");
-        initAplicomServer("aplicom");
-        initGotopServer("gotop");
-        initSanavServer("sanav");
-        initGatorServer("gator");
-        initNoranServer("noran");
-        initM2mServer("m2m");
-        initOsmAndServer("osmand");
-        initEasyTrackServer("easytrack");
-        initTaipServer("taip");
-        initKhdServer("khd");
-        initPiligrimServer("piligrim");
-        initStl060Server("stl060");
-        initCarTrackServer("cartrack");
-        initMiniFinderServer("minifinder");
-        initHaicomServer("haicom");
-        initEelinkServer("eelink");
-        initBoxServer("box");
-        initFreedomServer("freedom");
-        initTelikServer("telik");
-        initTrackboxServer("trackbox");
-        initVisiontekServer("visiontek");
-        initOrionServer("orion");
-        initRitiServer("riti");
-        initUlbotechServer("ulbotech");
-        initTramigoServer("tramigo");
-        initTr900Server("tr900");
-        initArdi01Server("ardi01");
-        initXt013Server("xt013");
-        initAutoFonServer("autofon");
-        initGoSafeServer("gosafe");
-        initAutoFon45Server("autofon45");
-        initBceServer("bce");
-        initXirgoServer("xirgo");
-        initCalAmpServer("calamp");
-        initMtxServer("mtx");
-        initTytanServer("tytan");
-        initAvl301Server("avl301");
-        initCastelServer("castel");
-        initMxtServer("mxt");
+        initProtocolServer(new Gps103Protocol());
+        initProtocolServer(new Tk103Protocol());
+        initProtocolServer(new Gl100Protocol());
+        initProtocolServer(new Gl200Protocol());
+        initProtocolServer(new T55Protocol());
+        initProtocolServer(new XexunProtocol());
+        initProtocolServer(new TotemProtocol());
+        initProtocolServer(new EnforaProtocol());
+        initProtocolServer(new MeiligaoProtocol());
+        initProtocolServer(new MaxonProtocol());
+        initProtocolServer(new SuntechProtocol());
+        initProtocolServer(new ProgressProtocol());
+        initProtocolServer(new H02Protocol());
+        initProtocolServer(new Jt600Protocol());
+        initProtocolServer(new Ev603Protocol());
+        initProtocolServer(new V680Protocol());
+        initProtocolServer(new Pt502Protocol());
+        initProtocolServer(new Tr20Protocol());
+        initProtocolServer(new NavisProtocol());
+        initProtocolServer(new MeitrackProtocol());
+        initProtocolServer(new SkypatrolProtocol());
+        initProtocolServer(new Gt02Protocol());
+        initProtocolServer(new Gt06Protocol());
+        initProtocolServer(new MegastekProtocol());
+        initProtocolServer(new NavigilProtocol());
+        initProtocolServer(new GpsGateProtocol());
+        initProtocolServer(new TeltonikaProtocol());
+        initProtocolServer(new Mta6Protocol());
+        initProtocolServer(new Mta6canProtocol());
+        initProtocolServer(new Tlt2hProtocol());
+        initProtocolServer(new SyrusProtocol());
+        initProtocolServer(new WondexProtocol());
+        initProtocolServer(new CellocatorProtocol());
+        initProtocolServer(new GalileoProtocol());
+        initProtocolServer(new YwtProtocol());
+        initProtocolServer(new Tk102Protocol());
+        initProtocolServer(new IntellitracProtocol());
+        initProtocolServer(new Xt7Protocol());
+        initProtocolServer(new WialonProtocol());
+        initProtocolServer(new CarscopProtocol());
+        initProtocolServer(new ApelProtocol());
+        initProtocolServer(new ManPowerProtocol());
+        initProtocolServer(new GlobalSatProtocol());
+        initProtocolServer(new AtrackProtocol());
+        initProtocolServer(new Pt3000Protocol());
+        initProtocolServer(new RuptelaProtocol());
+        initProtocolServer(new TopflytechProtocol());
+        initProtocolServer(new LaipacProtocol());
+        initProtocolServer(new AplicomProtocol());
+        initProtocolServer(new GotopProtocol());
+        initProtocolServer(new SanavProtocol());
+        initProtocolServer(new GatorProtocol());
+        initProtocolServer(new NoranProtocol());
+        initProtocolServer(new M2mProtocol());
+        initProtocolServer(new OsmAndProtocol());
+        initProtocolServer(new EasyTrackProtocol());
+        initProtocolServer(new TaipProtocol());
+        initProtocolServer(new KhdProtocol());
+        initProtocolServer(new PiligrimProtocol());
+        initProtocolServer(new Stl060Protocol());
+        initProtocolServer(new CarTrackProtocol());
+        initProtocolServer(new MiniFinderProtocol());
+        initProtocolServer(new HaicomProtocol());
+        initProtocolServer(new EelinkProtocol());
+        initProtocolServer(new BoxProtocol());
+        initProtocolServer(new FreedomProtocol());
+        initProtocolServer(new TelikProtocol());
+        initProtocolServer(new TrackboxProtocol());
+        initProtocolServer(new VisiontekProtocol());
+        initProtocolServer(new OrionProtocol());
+        initProtocolServer(new RitiProtocol());
+        initProtocolServer(new UlbotechProtocol());
+        initProtocolServer(new TramigoProtocol());
+        initProtocolServer(new Tr900Protocol());
+        initProtocolServer(new Ardi01Protocol());
+        initProtocolServer(new Xt013Protocol());
+        initProtocolServer(new AutoFonProtocol());
+        initProtocolServer(new GoSafeProtocol());
+        initProtocolServer(new AutoFon45Protocol());
+        initProtocolServer(new BceProtocol());
+        initProtocolServer(new XirgoProtocol());
+        initProtocolServer(new CalAmpProtocol());
+        initProtocolServer(new MtxProtocol());
+        initProtocolServer(new TytanProtocol());
+        initProtocolServer(new Avl301Protocol());
+        initProtocolServer(new CastelProtocol());
+        initProtocolServer(new MxtProtocol());
 
         initProtocolDetector();
     }
@@ -168,1204 +167,9 @@ public class ServerManager {
         }
     }
 
-    private void initGps103Server(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new CharacterDelimiterFrameDecoder(1024, "\r\n", "\n", ";"));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("stringEncoder", new StringEncoder());
-                    pipeline.addLast("objectDecoder", new Gps103ProtocolDecoder(protocol));
-                }
-            });
-            serverList.add(new TrackerServer(new ConnectionlessBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("stringEncoder", new StringEncoder());
-                    pipeline.addLast("objectDecoder", new Gps103ProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initTk103Server(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new CharacterDelimiterFrameDecoder(1024, ')'));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("stringEncoder", new StringEncoder());
-                    pipeline.addLast("objectDecoder", new Tk103ProtocolDecoder(protocol));
-                }
-            });
-            serverList.add(new TrackerServer(new ConnectionlessBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("stringEncoder", new StringEncoder());
-                    pipeline.addLast("objectDecoder", new Tk103ProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initGl100Server(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new CharacterDelimiterFrameDecoder(1024, '\0'));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("stringEncoder", new StringEncoder());
-                    pipeline.addLast("objectDecoder", new Gl100ProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initGl200Server(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new CharacterDelimiterFrameDecoder(1024, "$", "\0"));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("stringEncoder", new StringEncoder());
-                    pipeline.addLast("objectDecoder", new Gl200ProtocolDecoder(protocol));
-                }
-            });
-            
-            serverList.add(new TrackerServer(new ConnectionlessBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("stringEncoder", new StringEncoder());
-                    pipeline.addLast("objectDecoder", new Gl200ProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initT55Server(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new LineBasedFrameDecoder(1024));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("stringEncoder", new StringEncoder());
-                    pipeline.addLast("objectDecoder", new T55ProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initXexunServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    if (Boolean.valueOf(Context.getProps().getProperty(protocol + ".extended"))) {
-                        pipeline.addLast("frameDecoder", new LineBasedFrameDecoder(1024)); // tracker bug \n\r
-                        pipeline.addLast("stringDecoder", new StringDecoder());
-                        pipeline.addLast("objectDecoder", new Xexun2ProtocolDecoder(protocol));
-                    } else {
-                        pipeline.addLast("frameDecoder", new XexunFrameDecoder());
-                        pipeline.addLast("stringDecoder", new StringDecoder());
-                        pipeline.addLast("objectDecoder", new XexunProtocolDecoder(protocol));
-                    }
-                }
-            });
-        }
-    }
-
-    private void initTotemServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new TotemFrameDecoder());
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("objectDecoder", new TotemProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initEnforaServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new LengthFieldBasedFrameDecoder(1024, 0, 2, -2, 2));
-                    pipeline.addLast("objectDecoder", new EnforaProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initMeiligaoServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new MeiligaoFrameDecoder());
-                    pipeline.addLast("objectDecoder", new MeiligaoProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initMaxonServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new LineBasedFrameDecoder(1024));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("stringEncoder", new StringEncoder());
-                    pipeline.addLast("objectDecoder", new MaxonProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initSuntechServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new CharacterDelimiterFrameDecoder(1024, '\r'));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("objectDecoder", new SuntechProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initProgressServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            TrackerServer server = new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new LengthFieldBasedFrameDecoder(1024, 2, 2, 4, 0));
-                    pipeline.addLast("objectDecoder", new ProgressProtocolDecoder(protocol));
-                }
-            };
-            server.setEndianness(ByteOrder.LITTLE_ENDIAN);
-            serverList.add(server);
-        }
-    }
-
-    private void initH02Server(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new H02FrameDecoder());
-                    pipeline.addLast("objectDecoder", new H02ProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initJt600Server(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new Jt600FrameDecoder());
-                    pipeline.addLast("objectDecoder", new Jt600ProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initEv603Server(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new CharacterDelimiterFrameDecoder(1024, ';'));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("objectDecoder", new Ev603ProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initV680Server(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new CharacterDelimiterFrameDecoder(1024, "##"));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("objectDecoder", new V680ProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initPt502Server(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            TrackerServer server = new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new Pt502FrameDecoder());
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("objectDecoder", new Pt502ProtocolDecoder(protocol));
-                }
-            };
-            server.setEndianness(ByteOrder.LITTLE_ENDIAN);
-            serverList.add(server);
-        }
-    }
-
-    private void initTr20Server(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new LineBasedFrameDecoder(1024));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("stringEncoder", new StringEncoder());
-                    pipeline.addLast("objectDecoder", new Tr20ProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initNavisServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            TrackerServer server = new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new LengthFieldBasedFrameDecoder(4 * 1024, 12, 2, 2, 0));
-                    pipeline.addLast("objectDecoder", new NavisProtocolDecoder(protocol));
-                }
-            };
-            server.setEndianness(ByteOrder.LITTLE_ENDIAN);
-            serverList.add(server);
-        }
-    }
-
-    private void initMeitrackServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            TrackerServer server = new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new MeitrackFrameDecoder());
-                    pipeline.addLast("stringEncoder", new StringEncoder());
-                    pipeline.addLast("objectDecoder", new MeitrackProtocolDecoder(protocol));
-                }
-            };
-            server.setEndianness(ByteOrder.LITTLE_ENDIAN);
-            serverList.add(server);
-        }
-    }
-
-    private void initSkypatrolServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ConnectionlessBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("objectDecoder", new SkypatrolProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initGt02Server(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new LengthFieldBasedFrameDecoder(256, 2, 1, 2, 0));
-                    pipeline.addLast("objectDecoder", new Gt02ProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initGt06Server(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new Gt06FrameDecoder());
-                    pipeline.addLast("objectDecoder", new Gt06ProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initMegastekServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new LineBasedFrameDecoder(1024));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("stringEncoder", new StringEncoder());
-                    pipeline.addLast("objectDecoder", new MegastekProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initNavigilServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            TrackerServer server = new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new NavigilFrameDecoder());
-                    pipeline.addLast("objectDecoder", new NavigilProtocolDecoder(protocol));
-                }
-            };
-            server.setEndianness(ByteOrder.LITTLE_ENDIAN);
-            serverList.add(server);
-        }
-    }
-
-    private void initGpsGateServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new LineBasedFrameDecoder(1024));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("stringEncoder", new StringEncoder());
-                    pipeline.addLast("objectDecoder", new GpsGateProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initTeltonikaServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new TeltonikaFrameDecoder());
-                    pipeline.addLast("objectDecoder", new TeltonikaProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-    
-    private void initMta6Server(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("httpDecoder", new HttpRequestDecoder());
-                    pipeline.addLast("httpEncoder", new HttpResponseEncoder());
-                    pipeline.addLast("objectDecoder", new Mta6ProtocolDecoder(protocol, false));
-                }
-            });
-        }
-    }
-
-    private void initMta6CanServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("httpDecoder", new HttpRequestDecoder());
-                    pipeline.addLast("httpEncoder", new HttpResponseEncoder());
-                    pipeline.addLast("objectDecoder", new Mta6ProtocolDecoder(protocol, true));
-                }
-            });
-        }
-    }
-    
-    private void initTlt2hServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new CharacterDelimiterFrameDecoder(32 * 1024, "##"));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("stringEncoder", new StringEncoder());
-                    pipeline.addLast("objectDecoder", new Tlt2hProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-    
-    private void initSyrusServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new CharacterDelimiterFrameDecoder(1024, '<'));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("stringEncoder", new StringEncoder());
-                    pipeline.addLast("objectDecoder", new SyrusProtocolDecoder(protocol, true));
-                }
-            });
-        }
-    }
-
-    private void initWondexServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new WondexFrameDecoder());
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("objectDecoder", new WondexProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initCellocatorServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            TrackerServer server = new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new CellocatorFrameDecoder());
-                    pipeline.addLast("objectDecoder", new CellocatorProtocolDecoder(protocol));
-                }
-            };
-            server.setEndianness(ByteOrder.LITTLE_ENDIAN);
-            serverList.add(server);
-        }
-    }
-
-    private void initGalileoServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            TrackerServer server = new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new GalileoFrameDecoder());
-                    pipeline.addLast("objectDecoder", new GalileoProtocolDecoder(protocol));
-                }
-            };
-            server.setEndianness(ByteOrder.LITTLE_ENDIAN);
-            serverList.add(server);
-        }
-    }
-
-    private void initYwtServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new LineBasedFrameDecoder(1024));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("stringEncoder", new StringEncoder());
-                    pipeline.addLast("objectDecoder", new YwtProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initTk102Server(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new CharacterDelimiterFrameDecoder(1024, ']'));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("stringEncoder", new StringEncoder());
-                    pipeline.addLast("objectDecoder", new Tk102ProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-    
-    private void initIntellitracServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new IntellitracFrameDecoder(1024));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("stringEncoder", new StringEncoder());
-                    pipeline.addLast("objectDecoder", new IntellitracProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initXt7Server(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new LengthFieldBasedFrameDecoder(256, 20, 1, 5, 0));
-                    pipeline.addLast("objectDecoder", new Xt7ProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initWialonServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new LineBasedFrameDecoder(4 * 1024));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("stringEncoder", new StringEncoder());
-                    pipeline.addLast("objectDecoder", new WialonProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initCarscopServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new CharacterDelimiterFrameDecoder(1024, '^'));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("stringEncoder", new StringEncoder());
-                    pipeline.addLast("objectDecoder", new CarscopProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initApelServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            TrackerServer server = new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new LengthFieldBasedFrameDecoder(1024, 2, 2, 4, 0));
-                    pipeline.addLast("objectDecoder", new ApelProtocolDecoder(protocol));
-                }
-            };
-            server.setEndianness(ByteOrder.LITTLE_ENDIAN);
-            serverList.add(server);
-        }
-    }
-
-    private void initManPowerServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new CharacterDelimiterFrameDecoder(1024, ';'));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("stringEncoder", new StringEncoder());
-                    pipeline.addLast("objectDecoder", new ManPowerProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initGlobalSatServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new CharacterDelimiterFrameDecoder(1024, '!'));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("stringEncoder", new StringEncoder());
-                    pipeline.addLast("objectDecoder", new GlobalSatProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initAtrackServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new AtrackFrameDecoder());
-                    pipeline.addLast("objectDecoder", new AtrackProtocolDecoder(protocol));
-                }
-            });
-            serverList.add(new TrackerServer(new ConnectionlessBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("objectDecoder", new AtrackProtocolDecoder(protocol));
-                }
-            });
-
-        }
-    }
-
-    private void initPt3000Server(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new CharacterDelimiterFrameDecoder(1024, 'd')); // probably wrong
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("stringEncoder", new StringEncoder());
-                    pipeline.addLast("objectDecoder", new Pt3000ProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initRuptelaServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new LengthFieldBasedFrameDecoder(1024, 0, 2, 2, 0));
-                    pipeline.addLast("objectDecoder", new RuptelaProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initTopflytechServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new CharacterDelimiterFrameDecoder(1024, ')'));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("objectDecoder", new TopflytechProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initLaipacServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new LineBasedFrameDecoder(1024));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("stringEncoder", new StringEncoder());
-                    pipeline.addLast("objectDecoder", new LaipacProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initAplicomServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new AplicomFrameDecoder());
-                    pipeline.addLast("objectDecoder", new AplicomProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initGotopServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new CharacterDelimiterFrameDecoder(1024, '#'));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("objectDecoder", new GotopProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initSanavServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new CharacterDelimiterFrameDecoder(1024, '*'));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("objectDecoder", new SanavProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initGatorServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ConnectionlessBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("objectDecoder", new GatorProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initNoranServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            TrackerServer server = new TrackerServer(new ConnectionlessBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("objectDecoder", new NoranProtocolDecoder(protocol));
-                }
-            };
-            server.setEndianness(ByteOrder.LITTLE_ENDIAN);
-            serverList.add(server);
-        }
-    }
-
-    private void initM2mServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new FixedLengthFrameDecoder(23));
-                    pipeline.addLast("objectDecoder", new M2mProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-    
-    private void initOsmAndServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("httpDecoder", new HttpRequestDecoder());
-                    pipeline.addLast("httpEncoder", new HttpResponseEncoder());
-                    pipeline.addLast("objectDecoder", new OsmAndProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initEasyTrackServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new CharacterDelimiterFrameDecoder(1024, '#'));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("objectDecoder", new EasyTrackProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initTaipServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ConnectionlessBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("objectDecoder", new SyrusProtocolDecoder(protocol, false));
-                }
-            });
-        }
-    }
-
-    private void initKhdServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new LengthFieldBasedFrameDecoder(256, 3, 2));
-                    pipeline.addLast("objectDecoder", new KhdProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-    
-    private void initPiligrimServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("httpDecoder", new HttpRequestDecoder());
-                    pipeline.addLast("httpAggregator", new HttpChunkAggregator(16384));
-                    pipeline.addLast("httpEncoder", new HttpResponseEncoder());
-                    pipeline.addLast("objectDecoder", new PiligrimProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initStl060Server(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new Stl060FrameDecoder(1024));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("objectDecoder", new Stl060ProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initCarTrackServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new CharacterDelimiterFrameDecoder(1024, "##"));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("objectDecoder", new CarTrackProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initMiniFinderServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new CharacterDelimiterFrameDecoder(1024, ';'));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("objectDecoder", new MiniFinderProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initHaicomServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new CharacterDelimiterFrameDecoder(1024, '*'));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("objectDecoder", new HaicomProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initEelinkServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new LengthFieldBasedFrameDecoder(1024, 3, 2));
-                    pipeline.addLast("objectDecoder", new EelinkProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initBoxServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new CharacterDelimiterFrameDecoder(1024, '\r'));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("objectDecoder", new BoxProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initFreedomServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new LineBasedFrameDecoder(1024));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("objectDecoder", new FreedomProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initTelikServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new CharacterDelimiterFrameDecoder(1024, '\0'));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("objectDecoder", new TelikProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initTrackboxServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new LineBasedFrameDecoder(1024));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("stringEncoder", new StringEncoder());
-                    pipeline.addLast("objectDecoder", new TrackboxProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initVisiontekServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new CharacterDelimiterFrameDecoder(1024, '#'));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("objectDecoder", new VisiontekProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initOrionServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            TrackerServer server = new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new OrionFrameDecoder());
-                    pipeline.addLast("objectDecoder", new OrionProtocolDecoder(protocol));
-                }
-            };
-            server.setEndianness(ByteOrder.LITTLE_ENDIAN);
-            serverList.add(server);
-        }
-    }
-
-    private void initRitiServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            TrackerServer server = new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new LengthFieldBasedFrameDecoder(1024, 105, 2, 3, 0));
-                    pipeline.addLast("objectDecoder", new RitiProtocolDecoder(protocol));
-                }
-            };
-            server.setEndianness(ByteOrder.LITTLE_ENDIAN);
-            serverList.add(server);
-        }
-    }
-
-    private void initUlbotechServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new UlbotechFrameDecoder());
-                    pipeline.addLast("objectDecoder", new UlbotechProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initTramigoServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            TrackerServer server = new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new TramigoFrameDecoder());
-                    pipeline.addLast("objectDecoder", new TramigoProtocolDecoder(protocol));
-                }
-            };
-            server.setEndianness(ByteOrder.LITTLE_ENDIAN);
-            serverList.add(server);
-        }
-    }
-
-    private void initTr900Server(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new LineBasedFrameDecoder(1024));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("stringEncoder", new StringEncoder());
-                    pipeline.addLast("objectDecoder", new Tr900ProtocolDecoder(protocol));
-                }
-            });
-            serverList.add(new TrackerServer(new ConnectionlessBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("stringEncoder", new StringEncoder());
-                    pipeline.addLast("objectDecoder", new Tr900ProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initArdi01Server(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new LineBasedFrameDecoder(1024));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("objectDecoder", new Ardi01ProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initXt013Server(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new LineBasedFrameDecoder(1024));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("objectDecoder", new Xt013ProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initAutoFonServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new AutoFonFrameDecoder());
-                    pipeline.addLast("objectDecoder", new AutoFonProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initGoSafeServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new CharacterDelimiterFrameDecoder(1024, '#'));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("objectDecoder", new GoSafeProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initAutoFon45Server(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new AutoFon45FrameDecoder());
-                    pipeline.addLast("objectDecoder", new AutoFon45ProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initBceServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            TrackerServer server = new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new BceFrameDecoder());
-                    pipeline.addLast("objectDecoder", new BceProtocolDecoder(protocol));
-                }
-            };
-            server.setEndianness(ByteOrder.LITTLE_ENDIAN);
-            serverList.add(server);
-        }
-    }
-    
-    private void initXirgoServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new CharacterDelimiterFrameDecoder(1024, "##"));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("stringEncoder", new StringEncoder());
-                    pipeline.addLast("objectDecoder", new XirgoProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initCalAmpServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ConnectionlessBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("objectDecoder", new CalAmpProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-    
-    private void initMtxServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new LineBasedFrameDecoder(1024));
-                    pipeline.addLast("stringDecoder", new StringDecoder());
-                    pipeline.addLast("stringEncoder", new StringEncoder());
-                    pipeline.addLast("objectDecoder", new MtxProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initTytanServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ConnectionlessBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("objectDecoder", new TytanProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initAvl301Server(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            serverList.add(new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new LengthFieldBasedFrameDecoder(256, 2, 1, -3, 0));
-                    pipeline.addLast("objectDecoder", new Avl301ProtocolDecoder(protocol));
-                }
-            });
-        }
-    }
-
-    private void initCastelServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            TrackerServer server = new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new LengthFieldBasedFrameDecoder(1024, 2, 2, -4, 0));
-                    pipeline.addLast("objectDecoder", new CastelProtocolDecoder(protocol));
-                }
-            };
-            server.setEndianness(ByteOrder.LITTLE_ENDIAN);
-            serverList.add(server);
-
-            server = new TrackerServer(new ConnectionlessBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("objectDecoder", new CastelProtocolDecoder(protocol));
-                }
-            };
-            server.setEndianness(ByteOrder.LITTLE_ENDIAN);
-            serverList.add(server);
-        }
-    }
-
-    private void initMxtServer(final String protocol) throws SQLException {
-        if (isProtocolEnabled(protocol)) {
-            TrackerServer server = new TrackerServer(new ServerBootstrap(), protocol) {
-                @Override
-                protected void addSpecificHandlers(ChannelPipeline pipeline) {
-                    pipeline.addLast("frameDecoder", new MxtFrameDecoder());
-                    pipeline.addLast("objectDecoder", new MxtProtocolDecoder(protocol));
-                }
-            };
-            server.setEndianness(ByteOrder.LITTLE_ENDIAN);
-            serverList.add(server);
+    private void initProtocolServer(final Protocol protocol) throws SQLException {
+        if (isProtocolEnabled(protocol.getName())) {
+            protocol.addTrackerServersTo(serverList);
         }
     }