|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
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. |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |