public class UNSUBSCRIBE extends MessageSupport.HeaderBase implements MessageSupport.Message, MessageSupport.Acked
Modifier and Type | Field and Description |
---|---|
static org.fusesource.hawtbuf.UTF8Buffer[] |
NO_TOPICS |
static byte |
TYPE |
header
Constructor and Description |
---|
UNSUBSCRIBE() |
Modifier and Type | Method and Description |
---|---|
UNSUBSCRIBE |
decode(MQTTFrame frame) |
boolean |
dup() |
UNSUBSCRIBE |
dup(boolean dup) |
MQTTFrame |
encode() |
short |
messageId() |
UNSUBSCRIBE |
messageId(short messageId) |
byte |
messageType() |
QoS |
qos() |
org.fusesource.hawtbuf.UTF8Buffer[] |
topics() |
UNSUBSCRIBE |
topics(org.fusesource.hawtbuf.UTF8Buffer[] topics) |
String |
toString() |
commandType, header, header, qos, retain, retain
public static final byte TYPE
public static final org.fusesource.hawtbuf.UTF8Buffer[] NO_TOPICS
public byte messageType()
messageType
in interface MessageSupport.Message
messageType
in class MessageSupport.HeaderBase
public UNSUBSCRIBE decode(MQTTFrame frame) throws ProtocolException
decode
in interface MessageSupport.Message
ProtocolException
public MQTTFrame encode()
encode
in interface MessageSupport.Message
public boolean dup()
dup
in interface MessageSupport.Acked
dup
in class MessageSupport.HeaderBase
public UNSUBSCRIBE dup(boolean dup)
dup
in interface MessageSupport.Acked
dup
in class MessageSupport.HeaderBase
public QoS qos()
qos
in interface MessageSupport.Acked
qos
in class MessageSupport.HeaderBase
public short messageId()
messageId
in interface MessageSupport.Acked
public UNSUBSCRIBE messageId(short messageId)
messageId
in interface MessageSupport.Acked
public org.fusesource.hawtbuf.UTF8Buffer[] topics()
public UNSUBSCRIBE topics(org.fusesource.hawtbuf.UTF8Buffer[] topics)
Copyright © 2010-2013 FuseSource, Corp.. All Rights Reserved.