/* * 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.util.List; import org.jboss.netty.channel.*; import org.jboss.netty.handler.timeout.IdleStateAwareChannelHandler; import org.jboss.netty.handler.timeout.IdleStateEvent; import org.traccar.helper.Log; import org.traccar.model.DataManager; import org.traccar.model.Position; /** * Tracker message handler */ @ChannelHandler.Sharable public class TrackerEventHandler extends IdleStateAwareChannelHandler { /** * Data manager */ private DataManager dataManager; TrackerEventHandler(DataManager newDataManager) { super(); dataManager = newDataManager; } private void processSinglePosition(Position position) { if (position == null) { Log.info("null message"); } else { Log.info( "id: " + position.getId() + ", deviceId: " + position.getDeviceId() + ", valid: " + position.getValid() + ", time: " + position.getTime() + ", latitude: " + position.getLatitude() + ", longitude: " + position.getLongitude() + ", altitude: " + position.getAltitude() + ", speed: " + position.getSpeed() + ", course: " + position.getCourse() + ", power: " + position.getPower()); } // Write position to database try { dataManager.addPosition(position); } catch (Exception error) { Log.info("Exception during query execution"); Log.warning(error.getMessage()); } } @Override public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) { if (e.getMessage() instanceof Position) { processSinglePosition((Position) e.getMessage()); } else if (e.getMessage() instanceof List) { List<Position> positions = (List<Position>) e.getMessage(); for (Position position : positions) { processSinglePosition(position); } } } @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(); } }