|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use MqttWireMessage | |
---|---|
org.eclipse.paho.client.mqttv3.internal | |
org.eclipse.paho.client.mqttv3.internal.wire |
Uses of MqttWireMessage in org.eclipse.paho.client.mqttv3.internal |
---|
Methods in org.eclipse.paho.client.mqttv3.internal that return MqttWireMessage | |
---|---|
protected MqttWireMessage |
ClientState.get()
This returns the next piece of work, ie message, for the CommsSender to send over the network. |
MqttWireMessage |
Token.getWireMessage()
|
protected MqttWireMessage |
Token.waitForResponse()
Waits for the message delivery to complete, but doesn't throw an exception in the case of a NACK. |
protected MqttWireMessage |
Token.waitForResponse(long timeout)
|
Methods in org.eclipse.paho.client.mqttv3.internal with parameters of type MqttWireMessage | |
---|---|
MqttToken |
CommsTokenStore.getToken(MqttWireMessage message)
Based on the message type that has just been received return the associated token from the token store or null if one does not exist. |
protected void |
Token.markComplete(MqttWireMessage msg,
MqttException ex)
Mark the token as complete and ready for users to be notified. |
protected void |
ClientState.notifyReceivedMsg(MqttWireMessage message)
Called by the CommsReceiver when a message has been received. |
protected void |
ClientState.notifyResult(MqttWireMessage ack,
MqttToken token,
MqttException ex)
|
protected void |
ClientState.notifySent(MqttWireMessage message)
Called by the CommsSender when a message has been sent |
MqttToken |
CommsTokenStore.removeToken(MqttWireMessage message)
|
protected void |
CommsTokenStore.saveToken(MqttToken token,
MqttWireMessage message)
|
void |
ClientState.send(MqttWireMessage message,
MqttToken token)
Submits a message for delivery. |
void |
ClientComms.sendNoWait(MqttWireMessage message,
MqttToken token)
Sends a message to the broker if in connected state, but only waits for the message to be stored, before returning. |
Uses of MqttWireMessage in org.eclipse.paho.client.mqttv3.internal.wire |
---|
Subclasses of MqttWireMessage in org.eclipse.paho.client.mqttv3.internal.wire | |
---|---|
class |
MqttAck
Abstract super-class of all acknowledgement messages. |
class |
MqttConnack
An on-the-wire representation of an MQTT CONNACK. |
class |
MqttConnect
An on-the-wire representation of an MQTT CONNECT message. |
class |
MqttDisconnect
An on-the-wire representation of an MQTT DISCONNECT message. |
class |
MqttPersistableWireMessage
|
class |
MqttPingReq
An on-the-wire representation of an MQTT PINGREQ message. |
class |
MqttPingResp
An on-the-wire representation of an MQTT PINGRESP. |
class |
MqttPubAck
An on-the-wire representation of an MQTT PUBACK message. |
class |
MqttPubComp
An on-the-wire representation of an MQTT PUBCOMP message. |
class |
MqttPublish
An on-the-wire representation of an MQTT SEND message. |
class |
MqttPubRec
An on-the-wire representation of an MQTT PUBREC message. |
class |
MqttPubRel
An on-the-wire representation of an MQTT PUBREL message. |
class |
MqttSuback
An on-the-wire representation of an MQTT SUBACK. |
class |
MqttSubscribe
An on-the-wire representation of an MQTT SUBSCRIBE message. |
class |
MqttUnsubAck
An on-the-wire representation of an MQTT UNSUBACK. |
class |
MqttUnsubscribe
An on-the-wire representation of an MQTT UNSUBSCRIBE message. |
Methods in org.eclipse.paho.client.mqttv3.internal.wire that return MqttWireMessage | |
---|---|
static MqttWireMessage |
MqttWireMessage.createWireMessage(byte[] bytes)
|
static MqttWireMessage |
MqttWireMessage.createWireMessage(MqttPersistable data)
|
MqttWireMessage |
MqttInputStream.readMqttWireMessage()
Reads an MqttWireMessage from the stream. |
Methods in org.eclipse.paho.client.mqttv3.internal.wire with parameters of type MqttWireMessage | |
---|---|
void |
MqttOutputStream.write(MqttWireMessage message)
Writes an MqttWireMessage to the stream. |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |