From a1f07856053d5ee09987296c04ecde119c73b655 Mon Sep 17 00:00:00 2001 From: Scott Mitchell Date: Thu, 30 Jul 2015 10:19:17 -0700 Subject: [PATCH] MqttEncoder build failure Motivation: The MqttEncoder was failing to build because it was using a method that doesn't exist. Modifications: Change sessionPresent() to isSessionPresent(). Result: MqttEnccoder is now able to build. --- .../src/main/java/io/netty/handler/codec/mqtt/MqttEncoder.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/codec-mqtt/src/main/java/io/netty/handler/codec/mqtt/MqttEncoder.java b/codec-mqtt/src/main/java/io/netty/handler/codec/mqtt/MqttEncoder.java index eda2a8dde2..b1774d1ece 100644 --- a/codec-mqtt/src/main/java/io/netty/handler/codec/mqtt/MqttEncoder.java +++ b/codec-mqtt/src/main/java/io/netty/handler/codec/mqtt/MqttEncoder.java @@ -192,7 +192,7 @@ public class MqttEncoder extends MessageToMessageEncoder { ByteBuf buf = byteBufAllocator.buffer(4); buf.writeByte(getFixedHeaderByte1(message.fixedHeader())); buf.writeByte(2); - buf.writeByte(message.variableHeader().sessionPresent() ? 0x01 : 0x00); + buf.writeByte(message.variableHeader().isSessionPresent() ? 0x01 : 0x00); buf.writeByte(message.variableHeader().connectReturnCode().byteValue()); return buf;