public class SUBSCRIBE extends MessageSupport.HeaderBase implements MessageSupport.Message, MessageSupport.Acked
Modifier and Type | Field and Description |
---|---|
static Topic[] |
NO_TOPICS |
static byte |
TYPE |
header
Constructor and Description |
---|
SUBSCRIBE() |
Modifier and Type | Method and Description |
---|---|
SUBSCRIBE |
decode(MQTTFrame frame) |
boolean |
dup() |
SUBSCRIBE |
dup(boolean dup) |
MQTTFrame |
encode() |
short |
messageId() |
SUBSCRIBE |
messageId(short messageId) |
byte |
messageType() |
QoS |
qos() |
Topic[] |
topics() |
SUBSCRIBE |
topics(Topic[] topics) |
String |
toString() |
commandType, header, header, qos, retain, retain
public static final byte TYPE
public static final Topic[] NO_TOPICS
public byte messageType()
messageType
in interface MessageSupport.Message
messageType
in class MessageSupport.HeaderBase
public SUBSCRIBE 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 SUBSCRIBE 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 SUBSCRIBE messageId(short messageId)
messageId
in interface MessageSupport.Acked
public Topic[] topics()
Copyright © 2010–2017 FuseSource, Corp.. All rights reserved.