From f304021d16e433b261226a8293f03e7de30a08a4 Mon Sep 17 00:00:00 2001
From: Anton Tananaev <anton.tananaev@gmail.com>
Date: Sun, 12 Jul 2015 13:05:10 +1200
Subject: Re-factor all channel handlers

---
 src/org/traccar/ExtendedObjectDecoder.java | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

(limited to 'src/org/traccar/ExtendedObjectDecoder.java')

diff --git a/src/org/traccar/ExtendedObjectDecoder.java b/src/org/traccar/ExtendedObjectDecoder.java
index ad0210934..d0f82dace 100644
--- a/src/org/traccar/ExtendedObjectDecoder.java
+++ b/src/org/traccar/ExtendedObjectDecoder.java
@@ -16,6 +16,7 @@
 package org.traccar;
 
 import java.net.SocketAddress;
+import java.util.Collection;
 import org.jboss.netty.channel.Channel;
 import org.jboss.netty.channel.ChannelEvent;
 import org.jboss.netty.channel.ChannelHandlerContext;
@@ -39,7 +40,13 @@ public abstract class ExtendedObjectDecoder implements ChannelUpstreamHandler {
         if (originalMessage == decodedMessage) {
             ctx.sendUpstream(evt);
         } else if (decodedMessage != null) {
-            fireMessageReceived(ctx, decodedMessage, e.getRemoteAddress());
+            if (decodedMessage instanceof Collection) {
+                for (Object o : (Collection) e.getMessage()) {
+                    fireMessageReceived(ctx, o, e.getRemoteAddress());
+                }
+            } else {
+                fireMessageReceived(ctx, decodedMessage, e.getRemoteAddress());
+            }
         }
     }
     
-- 
cgit v1.2.3