Uses of Class
org.eclipse.paho.client.mqttv3.internal.wire.MqttWireMessage

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.
 



Copyright © 2013. All Rights Reserved.