aboutsummaryrefslogtreecommitdiff
path: root/src/org/traccar/protocol
diff options
context:
space:
mode:
Diffstat (limited to 'src/org/traccar/protocol')
-rw-r--r--src/org/traccar/protocol/MeiligaoProtocolDecoder.java10
1 files changed, 5 insertions, 5 deletions
diff --git a/src/org/traccar/protocol/MeiligaoProtocolDecoder.java b/src/org/traccar/protocol/MeiligaoProtocolDecoder.java
index 7e2aa062d..a63554fc4 100644
--- a/src/org/traccar/protocol/MeiligaoProtocolDecoder.java
+++ b/src/org/traccar/protocol/MeiligaoProtocolDecoder.java
@@ -112,7 +112,7 @@ public class MeiligaoProtocolDecoder extends BaseProtocolDecoder {
}
private static void sendResponse(
- Channel channel, ChannelBuffer id, int type, ChannelBuffer msg) {
+ Channel channel, SocketAddress remoteAddress, ChannelBuffer id, int type, ChannelBuffer msg) {
if (channel != null) {
ChannelBuffer buf = ChannelBuffers.buffer(
@@ -128,7 +128,7 @@ public class MeiligaoProtocolDecoder extends BaseProtocolDecoder {
buf.writeByte('\r');
buf.writeByte('\n');
- channel.write(buf);
+ channel.write(buf, remoteAddress);
}
}
@@ -157,20 +157,20 @@ public class MeiligaoProtocolDecoder extends BaseProtocolDecoder {
case MSG_LOGIN:
if (channel != null) {
response = ChannelBuffers.wrappedBuffer(new byte[] {0x01});
- sendResponse(channel, id, MSG_LOGIN_RESPONSE, response);
+ sendResponse(channel, remoteAddress, id, MSG_LOGIN_RESPONSE, response);
}
return null;
case MSG_HEARTBEAT:
if (channel != null) {
response = ChannelBuffers.wrappedBuffer(new byte[] {0x01});
- sendResponse(channel, id, MSG_HEARTBEAT, response);
+ sendResponse(channel, remoteAddress, id, MSG_HEARTBEAT, response);
}
return null;
case MSG_SERVER:
if (channel != null) {
response = ChannelBuffers.copiedBuffer(
getMeiligaoServer(channel), Charset.defaultCharset());
- sendResponse(channel, id, MSG_SERVER, response);
+ sendResponse(channel, remoteAddress, id, MSG_SERVER, response);
}
return null;
case MSG_POSITION: