Uses of Class
org.eclipse.paho.client.mqttv3.MqttException

Packages that use MqttException
org.eclipse.paho.client.mqttv3 Contains a programming interface enabling applications to communicate with an MQTT server. 
org.eclipse.paho.client.mqttv3.internal   
org.eclipse.paho.client.mqttv3.internal.wire   
 

Uses of MqttException in org.eclipse.paho.client.mqttv3
 

Subclasses of MqttException in org.eclipse.paho.client.mqttv3
 class MqttPersistenceException
          This exception is thrown by the implementor of the persistence interface if there is a problem reading or writing persistent data.
 class MqttSecurityException
          Thrown when a client is not authorized to perform an operation, or if there is a problem with the security configuration.
 

Methods in org.eclipse.paho.client.mqttv3 that return MqttException
 MqttException IMqttToken.getException()
          Returns an exception providing more detail if an operation failed.
 MqttException MqttToken.getException()
           
 

Methods in org.eclipse.paho.client.mqttv3 that throw MqttException
 void MqttClient.close()
           
 void IMqttAsyncClient.close()
          Close the client Releases all resource associated with the client.
 void IMqttClient.close()
          Close the client Releases all resource associated with the client.
 void MqttAsyncClient.close()
           
 void MqttClient.connect()
           
 IMqttToken IMqttAsyncClient.connect()
          Connects to an MQTT server using the default options.
 void IMqttClient.connect()
          Connects to an MQTT server using the default options.
 IMqttToken MqttAsyncClient.connect()
           
 void MqttClient.connect(MqttConnectOptions options)
           
 IMqttToken IMqttAsyncClient.connect(MqttConnectOptions options)
          Connects to an MQTT server using the provided connect options.
 void IMqttClient.connect(MqttConnectOptions options)
          Connects to an MQTT server using the specified options.
 IMqttToken MqttAsyncClient.connect(MqttConnectOptions options)
           
 IMqttToken IMqttAsyncClient.connect(MqttConnectOptions options, Object userContext, IMqttActionListener callback)
          Connects to an MQTT server using the specified options.
 IMqttToken MqttAsyncClient.connect(MqttConnectOptions options, Object userContext, IMqttActionListener callback)
           
 IMqttToken IMqttAsyncClient.connect(Object userContext, IMqttActionListener callback)
          Connects to an MQTT server using the default options.
 IMqttToken MqttAsyncClient.connect(Object userContext, IMqttActionListener callback)
           
protected  NetworkModule[] MqttAsyncClient.createNetworkModules(String address, MqttConnectOptions options)
          Factory method to create an array of network modules, one for each of the supplied URIs
 void MqttClient.disconnect()
           
 IMqttToken IMqttAsyncClient.disconnect()
          Disconnects from the server.
 void IMqttClient.disconnect()
          Disconnects from the server.
 IMqttToken MqttAsyncClient.disconnect()
           
 void MqttClient.disconnect(long quiesceTimeout)
           
 IMqttToken IMqttAsyncClient.disconnect(long quiesceTimeout)
          Disconnects from the server.
 void IMqttClient.disconnect(long quiesceTimeout)
          Disconnects from the server.
 IMqttToken MqttAsyncClient.disconnect(long quiesceTimeout)
           
 IMqttToken IMqttAsyncClient.disconnect(long quiesceTimeout, Object userContext, IMqttActionListener callback)
          Disconnects from the server.
 IMqttToken MqttAsyncClient.disconnect(long quiesceTimeout, Object userContext, IMqttActionListener callback)
           
 IMqttToken IMqttAsyncClient.disconnect(Object userContext, IMqttActionListener callback)
          Disconnects from the server.
 IMqttToken MqttAsyncClient.disconnect(Object userContext, IMqttActionListener callback)
           
 MqttMessage MqttDeliveryToken.getMessage()
          Returns the message associated with this token.
 MqttMessage IMqttDeliveryToken.getMessage()
          Returns the message associated with this token.
 MqttDeliveryToken MqttTopic.publish(byte[] payload, int qos, boolean retained)
          Publishes a message on the topic.
 MqttDeliveryToken MqttTopic.publish(MqttMessage message)
          Publishes the specified message to this topic, but does not wait for delivery of the message to complete.
 void MqttClient.publish(String topic, byte[] payload, int qos, boolean retained)
           
 IMqttDeliveryToken IMqttAsyncClient.publish(String topic, byte[] payload, int qos, boolean retained)
          Publishes a message to a topic on the server.
 void IMqttClient.publish(String topic, byte[] payload, int qos, boolean retained)
          Publishes a message to a topic on the server and return once it is delivered.
 IMqttDeliveryToken MqttAsyncClient.publish(String topic, byte[] payload, int qos, boolean retained)
           
 IMqttDeliveryToken IMqttAsyncClient.publish(String topic, byte[] payload, int qos, boolean retained, Object userContext, IMqttActionListener callback)
          Publishes a message to a topic on the server.
 IMqttDeliveryToken MqttAsyncClient.publish(String topic, byte[] payload, int qos, boolean retained, Object userContext, IMqttActionListener callback)
           
 void MqttClient.publish(String topic, MqttMessage message)
           
 IMqttDeliveryToken IMqttAsyncClient.publish(String topic, MqttMessage message)
          Publishes a message to a topic on the server.
 void IMqttClient.publish(String topic, MqttMessage message)
          Publishes a message to a topic on the server.
 IMqttDeliveryToken MqttAsyncClient.publish(String topic, MqttMessage message)
           
 IMqttDeliveryToken IMqttAsyncClient.publish(String topic, MqttMessage message, Object userContext, IMqttActionListener callback)
          Publishes a message to a topic on the server.
 IMqttDeliveryToken MqttAsyncClient.publish(String topic, MqttMessage message, Object userContext, IMqttActionListener callback)
           
 void MqttClient.subscribe(String topicFilter)
           
 void IMqttClient.subscribe(String topicFilter)
          Subscribe to a topic, which may include wildcards using a QoS of 1.
 void MqttClient.subscribe(String[] topicFilters)
           
 void IMqttClient.subscribe(String[] topicFilters)
          Subscribes to a one or more topics, which may include wildcards using a QoS of 1.
 void MqttClient.subscribe(String[] topicFilters, int[] qos)
           
 IMqttToken IMqttAsyncClient.subscribe(String[] topicFilters, int[] qos)
          Subscribe to multiple topics, each of which may include wildcards.
 void IMqttClient.subscribe(String[] topicFilters, int[] qos)
          Subscribes to multiple topics, each of which may include wildcards.
 IMqttToken MqttAsyncClient.subscribe(String[] topicFilters, int[] qos)
           
 IMqttToken IMqttAsyncClient.subscribe(String[] topicFilters, int[] qos, Object userContext, IMqttActionListener callback)
          Subscribes to multiple topics, each of which may include wildcards.
 IMqttToken MqttAsyncClient.subscribe(String[] topicFilters, int[] qos, Object userContext, IMqttActionListener callback)
           
 void MqttClient.subscribe(String topicFilter, int qos)
           
 IMqttToken IMqttAsyncClient.subscribe(String topicFilter, int qos)
          Subscribe to a topic, which may include wildcards.
 void IMqttClient.subscribe(String topicFilter, int qos)
          Subscribe to a topic, which may include wildcards.
 IMqttToken MqttAsyncClient.subscribe(String topicFilter, int qos)
           
 IMqttToken IMqttAsyncClient.subscribe(String topicFilter, int qos, Object userContext, IMqttActionListener callback)
          Subscribe to a topic, which may include wildcards.
 IMqttToken MqttAsyncClient.subscribe(String topicFilter, int qos, Object userContext, IMqttActionListener callback)
           
 void MqttClient.unsubscribe(String topicFilter)
           
 IMqttToken IMqttAsyncClient.unsubscribe(String topicFilter)
          Requests the server unsubscribe the client from a topic.
 void IMqttClient.unsubscribe(String topicFilter)
          Requests the server unsubscribe the client from a topic.
 IMqttToken MqttAsyncClient.unsubscribe(String topicFilter)
           
 void MqttClient.unsubscribe(String[] topicFilters)
           
 IMqttToken IMqttAsyncClient.unsubscribe(String[] topicFilters)
          Requests the server unsubscribe the client from one or more topics.
 void IMqttClient.unsubscribe(String[] topicFilters)
          Requests the server unsubscribe the client from one or more topics.
 IMqttToken MqttAsyncClient.unsubscribe(String[] topicFilters)
           
 IMqttToken IMqttAsyncClient.unsubscribe(String[] topicFilters, Object userContext, IMqttActionListener callback)
          Requests the server unsubscribe the client from one or more topics.
 IMqttToken MqttAsyncClient.unsubscribe(String[] topicFilters, Object userContext, IMqttActionListener callback)
           
 IMqttToken IMqttAsyncClient.unsubscribe(String topicFilter, Object userContext, IMqttActionListener callback)
          Requests the server unsubscribe the client from a topics.
 IMqttToken MqttAsyncClient.unsubscribe(String topicFilter, Object userContext, IMqttActionListener callback)
           
 void IMqttToken.waitForCompletion()
          Blocks the current thread until the action this token is associated with has completed.
 void MqttToken.waitForCompletion()
           
 void IMqttToken.waitForCompletion(long timeout)
          Blocks the current thread until the action this token is associated with has completed.
 void MqttToken.waitForCompletion(long timeout)
           
 

Constructors in org.eclipse.paho.client.mqttv3 that throw MqttException
MqttAsyncClient(String serverURI, String clientId)
          Create an MqttAsyncClient that is used to communicate with an MQTT server.
MqttAsyncClient(String serverURI, String clientId, MqttClientPersistence persistence)
          Create an MqttAsyncClient that is used to communicate with an MQTT server.
MqttClient(String serverURI, String clientId)
          Create an MqttClient that can be used to communicate with an MQTT server.
MqttClient(String serverURI, String clientId, MqttClientPersistence persistence)
          Create an MqttClient that can be used to communicate with an MQTT server.
 

Uses of MqttException in org.eclipse.paho.client.mqttv3.internal
 

Methods in org.eclipse.paho.client.mqttv3.internal that return MqttException
static MqttException ExceptionHelper.createMqttException(int reasonCode)
           
static MqttException ExceptionHelper.createMqttException(Throwable cause)
           
 MqttException Token.getException()
           
 

Methods in org.eclipse.paho.client.mqttv3.internal with parameters of type MqttException
 void ClientComms.connectComplete(MqttConnack cack, MqttException mex)
           
 void CommsCallback.connectionLost(MqttException cause)
          This method is called when the connection to the server is lost.
 void ClientState.disconnected(MqttException reason)
          Called when the client has been disconnected from the broker.
protected  void Token.markComplete(MqttWireMessage msg, MqttException ex)
          Mark the token as complete and ready for users to be notified.
protected  void ClientState.notifyResult(MqttWireMessage ack, MqttToken token, MqttException ex)
           
protected  void CommsTokenStore.quiesce(MqttException quiesceResponse)
           
 Vector ClientState.resolveOldTokens(MqttException reason)
          Called during shutdown to work out if there are any tokens still to be notified and waiters to be unblocked.
 void Token.setException(MqttException exception)
           
 void ClientComms.shutdownConnection(MqttToken token, MqttException reason)
          Shuts down the connection to the server.
 

Methods in org.eclipse.paho.client.mqttv3.internal that throw MqttException
 boolean Token.checkResult()
           
protected  void ClientState.clearState()
           
 void ClientComms.close()
          Close and tidy up.
 void ClientComms.connect(MqttConnectOptions options, MqttToken token)
          Sends a connect message and waits for an ACK or NACK.
 void ClientComms.connectComplete(MqttConnack cack, MqttException mex)
           
 void ClientComms.disconnect(MqttDisconnect disconnect, long quiesceTimeout, MqttToken token)
           
protected  MqttWireMessage ClientState.get()
          This returns the next piece of work, ie message, for the CommsSender to send over the network.
protected  void ClientState.notifyComplete(MqttToken token)
          Called when waiters and callbacks have processed the message.
protected  void ClientState.notifyReceivedAck(MqttAck ack)
          Called by the CommsReceiver when an ack has arrived.
protected  void ClientState.notifyReceivedMsg(MqttWireMessage message)
          Called by the CommsReceiver when a message has been received.
 void Token.reset()
           
protected  void ClientState.restoreState()
          Restores the state information from persistence.
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.
 void LocalNetworkModule.start()
           
 void SSLNetworkModule.start()
           
 void NetworkModule.start()
           
 void TCPNetworkModule.start()
          Starts the module, by creating a TCP socket to the server.
 void Token.waitForCompletion()
           
 void Token.waitForCompletion(long timeout)
           
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)
           
 void Token.waitUntilSent()
           
 

Constructors in org.eclipse.paho.client.mqttv3.internal that throw MqttException
ClientComms(IMqttAsyncClient client, MqttClientPersistence persistence)
          Creates a new ClientComms object, using the specified module to handle the network calls.
ClientState(MqttClientPersistence persistence, CommsTokenStore tokenStore, CommsCallback callback, ClientComms clientComms)
           
 

Uses of MqttException in org.eclipse.paho.client.mqttv3.internal.wire
 

Methods in org.eclipse.paho.client.mqttv3.internal.wire that throw MqttException
static MqttWireMessage MqttWireMessage.createWireMessage(byte[] bytes)
           
static MqttWireMessage MqttWireMessage.createWireMessage(MqttPersistable data)
           
protected  String MqttWireMessage.decodeUTF8(DataInputStream input)
          Decodes a UTF-8 string from the DataInputStream provided.
protected  byte[] MqttWireMessage.encodeMessageId()
           
protected  void MqttWireMessage.encodeUTF8(DataOutputStream dos, String stringToEncode)
          Encodes a String given into UTF-8, before writing this to the DataOutputStream the length of the encoded string is encoded into two bytes and then written to the DataOutputStream.
 byte[] MqttWireMessage.getHeader()
           
 byte[] MqttWireMessage.getPayload()
          Sub-classes should override this method to supply the payload bytes.
 byte[] MqttSubscribe.getPayload()
           
 byte[] MqttConnect.getPayload()
           
 byte[] MqttPublish.getPayload()
           
 byte[] MqttUnsubscribe.getPayload()
           
protected  byte[] MqttUnsubAck.getVariableHeader()
           
protected  byte[] MqttPingResp.getVariableHeader()
           
protected abstract  byte[] MqttWireMessage.getVariableHeader()
           
protected  byte[] MqttSuback.getVariableHeader()
           
protected  byte[] MqttSubscribe.getVariableHeader()
           
protected  byte[] MqttDisconnect.getVariableHeader()
           
protected  byte[] MqttConnect.getVariableHeader()
           
protected  byte[] MqttPublish.getVariableHeader()
           
protected  byte[] MqttConnack.getVariableHeader()
           
protected  byte[] MqttPubRel.getVariableHeader()
           
protected  byte[] MqttUnsubscribe.getVariableHeader()
           
protected  byte[] MqttPubRec.getVariableHeader()
           
protected  byte[] MqttPubComp.getVariableHeader()
           
protected  byte[] MqttPingReq.getVariableHeader()
           
protected  byte[] MqttPubAck.getVariableHeader()
           
 MqttWireMessage MqttInputStream.readMqttWireMessage()
          Reads an MqttWireMessage from the stream.
 void MqttOutputStream.write(MqttWireMessage message)
          Writes an MqttWireMessage to the stream.
 

Constructors in org.eclipse.paho.client.mqttv3.internal.wire that throw MqttException
MqttConnect(byte info, byte[] data)
          Constructor for an on the wire MQTT connect message
MqttPublish(byte info, byte[] data)
          Constructs a new MqttPublish object.
 



Copyright © 2013. All Rights Reserved.