From 1fe468bf5b004845e8904b66198597d28d37a029 Mon Sep 17 00:00:00 2001 From: Anton Tananaev Date: Tue, 12 Jun 2018 13:57:19 +1200 Subject: Migrate new protocols --- src/org/traccar/protocol/EsealProtocolDecoder.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) (limited to 'src/org/traccar/protocol/EsealProtocolDecoder.java') diff --git a/src/org/traccar/protocol/EsealProtocolDecoder.java b/src/org/traccar/protocol/EsealProtocolDecoder.java index 90f360d66..39c0d94c2 100644 --- a/src/org/traccar/protocol/EsealProtocolDecoder.java +++ b/src/org/traccar/protocol/EsealProtocolDecoder.java @@ -15,10 +15,11 @@ */ package org.traccar.protocol; -import org.jboss.netty.channel.Channel; +import io.netty.channel.Channel; import org.traccar.BaseProtocolDecoder; import org.traccar.Context; import org.traccar.DeviceSession; +import org.traccar.NetworkMessage; import org.traccar.helper.Parser; import org.traccar.helper.PatternBuilder; import org.traccar.helper.UnitsConverter; @@ -62,7 +63,8 @@ public class EsealProtocolDecoder extends BaseProtocolDecoder { private void sendResponse(Channel channel, String prefix, String type, String payload) { if (channel != null) { - channel.write(prefix + type + "," + payload + ",E##\r\n"); + channel.writeAndFlush(new NetworkMessage( + prefix + type + "," + payload + ",E##\r\n", channel.remoteAddress())); } } -- cgit v1.2.3