Re-factor all channel handlers

1 files changed, 0 insertions, 93 deletions

diff --git a/src/org/traccar/TrackerEventHandler.java b/src/org/traccar/TrackerEventHandler.java
deleted file mode 100644
index 31e6fb5cb..000000000
--- a/src/org/traccar/TrackerEventHandler.java
+++ /dev/null
@@ -1,93 +0,0 @@
-/*
- * Copyright 2012 - 2015 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.util.List;
-import org.jboss.netty.channel.ChannelHandler;
-import org.jboss.netty.channel.ChannelHandlerContext;
-import org.jboss.netty.channel.ChannelStateEvent;
-import org.jboss.netty.channel.ExceptionEvent;
-import org.jboss.netty.channel.MessageEvent;
-import org.jboss.netty.handler.timeout.IdleStateAwareChannelHandler;
-import org.jboss.netty.handler.timeout.IdleStateEvent;
-import org.traccar.helper.Log;
-import org.traccar.model.Position;
-
-@ChannelHandler.Sharable
-public class TrackerEventHandler extends IdleStateAwareChannelHandler {
-
-    private void processSinglePosition(Position position) {
-        if (position == null) {
-            Log.info("processSinglePosition null message");
-        } else {
-            StringBuilder s = new StringBuilder();
-            s.append("device: ").append(position.getDeviceId()).append(", ");
-            s.append("time: ").append(position.getFixTime()).append(", ");
-            s.append("lat: ").append(position.getLatitude()).append(", ");
-            s.append("lon: ").append(position.getLongitude());
-            Log.info(s.toString());
-        }
-
-        try {
-            Context.getDataManager().addPosition(position);
-        } catch (Exception error) {
-            Log.warning(error);
-        }
-    }
-
-    @Override
-    public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) {
-        Long id = null;
-        Position lastPostition = null;
-        if (e.getMessage() instanceof Position) {
-            processSinglePosition((Position) e.getMessage());
-            lastPostition = (Position) e.getMessage();
-        } else if (e.getMessage() instanceof List) {
-            List<Position> positions = (List<Position>) e.getMessage();
-            for (Position position : positions) {
-                processSinglePosition(position);
-                lastPostition = position;
-            }
-        }
-        if (lastPostition != null) {
-            try {
-                Context.getDataManager().updateLatestPosition(lastPostition);
-                Context.getConnectionManager().update(lastPostition);
-            } catch (Exception error) {
-                Log.warning(error);
-            }
-        }
-    }
-
-    @Override
-    public void channelDisconnected(ChannelHandlerContext ctx, ChannelStateEvent e) {
-        Log.info("Closing connection by disconnect");
-        e.getChannel().close();
-    }
-
-    @Override
-    public void exceptionCaught(ChannelHandlerContext ctx, ExceptionEvent e) {
-        Log.info("Closing connection by exception");
-        e.getChannel().close();
-    }
-
-    @Override
-    public void channelIdle(ChannelHandlerContext ctx, IdleStateEvent e) {
-        Log.info("Closing connection by timeout");
-        e.getChannel().close();
-    }
-
-}