andreacavalli/netty5
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Issue №6802. Not specified field in MQTT codec (#6807)

Browse Source
This commit is contained in:
Pavel Drankov 2017-06-06 00:21:49 +04:00 committed by Scott Mitchell
parent 24f801c7d1
commit f8788a9f6c
1 changed files with 13 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
codec-mqtt/src/main/java/io/netty/handler/codec/mqtt/MqttPublishVariableHeader.java
View File

@ -24,19 +24,27 @@ import io.netty.util.internal.StringUtil;
public final class MqttPublishVariableHeader { public final class MqttPublishVariableHeader {
private final String topicName; private final String topicName;
private final int messageId; private final int packetId;
public MqttPublishVariableHeader(String topicName, int messageId) { public MqttPublishVariableHeader(String topicName, int packetId) {
this.topicName = topicName; this.topicName = topicName;
this.messageId = messageId; this.packetId = packetId;
} }
public String topicName() { public String topicName() {
return topicName; return topicName;
} }
/**
* @deprecated Use {@link #packetId()} instead.
*/
@Deprecated
public int messageId() { public int messageId() {
return messageId; return packetId;
}
public int packetId() {
return packetId;
} }
@Override @Override
@ -44,7 +52,7 @@ public final class MqttPublishVariableHeader {
return new StringBuilder(StringUtil.simpleClassName(this)) return new StringBuilder(StringUtil.simpleClassName(this))
.append('[') .append('[')
.append("topicName=").append(topicName) .append("topicName=").append(topicName)
.append(", messageId=").append(messageId) .append(", packetId=").append(packetId)
.append(']') .append(']')
.toString(); .toString();
} }