From 4d88fa05bb1b673d676ff92b0b2b53bfba19cece Mon Sep 17 00:00:00 2001
From: Anton Tananaev <anton.tananaev@gmail.com>
Date: Sat, 9 Jun 2018 09:35:25 +1200
Subject: Migrate remaining protocols

---
 src/org/traccar/protocol/TaipProtocolDecoder.java | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

(limited to 'src/org/traccar/protocol/TaipProtocolDecoder.java')

diff --git a/src/org/traccar/protocol/TaipProtocolDecoder.java b/src/org/traccar/protocol/TaipProtocolDecoder.java
index ea5492462..31b435bce 100644
--- a/src/org/traccar/protocol/TaipProtocolDecoder.java
+++ b/src/org/traccar/protocol/TaipProtocolDecoder.java
@@ -15,9 +15,10 @@
  */
 package org.traccar.protocol;
 
-import org.jboss.netty.channel.Channel;
+import io.netty.channel.Channel;
 import org.traccar.BaseProtocolDecoder;
 import org.traccar.DeviceSession;
+import org.traccar.NetworkMessage;
 import org.traccar.helper.BitUtil;
 import org.traccar.helper.Checksum;
 import org.traccar.helper.DateBuilder;
@@ -271,9 +272,9 @@ public class TaipProtocolDecoder extends BaseProtocolDecoder {
                 if (messageIndex != null) {
                     String response = ">ACK;ID=" + uniqueId + ";" + messageIndex + ";*";
                     response += String.format("%02X", Checksum.xor(response)) + "<";
-                    channel.write(response, remoteAddress);
+                    channel.writeAndFlush(new NetworkMessage(response, remoteAddress));
                 } else {
-                    channel.write(uniqueId, remoteAddress);
+                    channel.writeAndFlush(new NetworkMessage(uniqueId, remoteAddress));
                 }
             }
             return position;
-- 
cgit v1.2.3