- read() - Method in class org.eclipse.paho.client.mqttv3.internal.wire.CountingInputStream
-
- read() - Method in class org.eclipse.paho.client.mqttv3.internal.wire.MqttInputStream
-
- read() - Method in class org.eclipse.paho.client.mqttv3.internal.wire.MultiByteArrayInputStream
-
- readMBI(DataInputStream) - Static method in class org.eclipse.paho.client.mqttv3.internal.wire.MqttWireMessage
-
Decodes an MQTT Multi-Byte Integer from the given stream.
- readMqttWireMessage() - Method in class org.eclipse.paho.client.mqttv3.internal.wire.MqttInputStream
-
Reads an MqttWireMessage
from the stream.
- REASON_CODE_BROKER_UNAVAILABLE - Static variable in exception org.eclipse.paho.client.mqttv3.MqttException
-
The broker was not available to handle the request.
- REASON_CODE_CLIENT_ALREADY_DISCONNECTED - Static variable in exception org.eclipse.paho.client.mqttv3.MqttException
-
The client is already disconnected.
- REASON_CODE_CLIENT_CLOSED - Static variable in exception org.eclipse.paho.client.mqttv3.MqttException
-
The client is closed - no operations are permitted on the client in this state.
- REASON_CODE_CLIENT_CONNECTED - Static variable in exception org.eclipse.paho.client.mqttv3.MqttException
-
The client is already connected.
- REASON_CODE_CLIENT_DISCONNECT_PROHIBITED - Static variable in exception org.eclipse.paho.client.mqttv3.MqttException
-
- REASON_CODE_CLIENT_DISCONNECTING - Static variable in exception org.eclipse.paho.client.mqttv3.MqttException
-
The client is currently disconnecting and cannot accept any new work.
- REASON_CODE_CLIENT_EXCEPTION - Static variable in exception org.eclipse.paho.client.mqttv3.MqttException
-
Client encountered an exception.
- REASON_CODE_CLIENT_NOT_CONNECTED - Static variable in exception org.eclipse.paho.client.mqttv3.MqttException
-
The client is not connected to the server.
- REASON_CODE_CLIENT_TIMEOUT - Static variable in exception org.eclipse.paho.client.mqttv3.MqttException
-
Client timed out while waiting for a response from the server.
- REASON_CODE_CONNECT_IN_PROGRESS - Static variable in exception org.eclipse.paho.client.mqttv3.MqttException
-
A connect operation in already in progress, only one connect can happen at a time.
- REASON_CODE_CONNECTION_LOST - Static variable in exception org.eclipse.paho.client.mqttv3.MqttException
-
The client has been unexpectedly disconnected from the server.
- REASON_CODE_FAILED_AUTHENTICATION - Static variable in exception org.eclipse.paho.client.mqttv3.MqttException
-
Authentication with the server has failed, due to a bad user name or password.
- REASON_CODE_INVALID_CLIENT_ID - Static variable in exception org.eclipse.paho.client.mqttv3.MqttException
-
The server has rejected the supplied client ID
- REASON_CODE_INVALID_MESSAGE - Static variable in exception org.eclipse.paho.client.mqttv3.MqttException
-
Protocol error: the message was not recognized as a valid MQTT packet.
- REASON_CODE_INVALID_PROTOCOL_VERSION - Static variable in exception org.eclipse.paho.client.mqttv3.MqttException
-
The protocol version requested is not supported by the server.
- REASON_CODE_MAX_INFLIGHT - Static variable in exception org.eclipse.paho.client.mqttv3.MqttException
-
A request has been made to send a message but the maximum number of inflight messages has already been reached.
- REASON_CODE_NO_MESSAGE_IDS_AVAILABLE - Static variable in exception org.eclipse.paho.client.mqttv3.MqttException
-
Internal error, caused by no new message IDs being available.
- REASON_CODE_NOT_AUTHORIZED - Static variable in exception org.eclipse.paho.client.mqttv3.MqttException
-
Not authorized to perform the requested operation
- REASON_CODE_PERSISTENCE_IN_USE - Static variable in exception org.eclipse.paho.client.mqttv3.MqttPersistenceException
-
Persistence is already being used by another client.
- REASON_CODE_SERVER_CONNECT_ERROR - Static variable in exception org.eclipse.paho.client.mqttv3.MqttException
-
Unable to connect to server
- REASON_CODE_SOCKET_FACTORY_MISMATCH - Static variable in exception org.eclipse.paho.client.mqttv3.MqttException
-
Server URI and supplied SocketFactory
do not match.
- REASON_CODE_SSL_CONFIG_ERROR - Static variable in exception org.eclipse.paho.client.mqttv3.MqttException
-
SSL configuration error.
- REASON_CODE_SUBSCRIBE_FAILED - Static variable in exception org.eclipse.paho.client.mqttv3.MqttException
-
Error from subscribe - returned from the server.
- REASON_CODE_TOKEN_INUSE - Static variable in exception org.eclipse.paho.client.mqttv3.MqttException
-
A request has been made to use a token that is already associated with another action.
- REASON_CODE_UNEXPECTED_ERROR - Static variable in exception org.eclipse.paho.client.mqttv3.MqttException
-
An unexpected error has occurred.
- REASON_CODE_WRITE_TIMEOUT - Static variable in exception org.eclipse.paho.client.mqttv3.MqttException
-
Client timed out while waiting to write messages to the server.
- remove(String) - Method in interface org.eclipse.paho.client.mqttv3.MqttClientPersistence
-
Remove the data for the specified key.
- remove(String) - Method in class org.eclipse.paho.client.mqttv3.persist.MemoryPersistence
-
- removeToken(MqttWireMessage) - Method in class org.eclipse.paho.client.mqttv3.internal.CommsTokenStore
-
- removeToken(String) - Method in class org.eclipse.paho.client.mqttv3.internal.CommsTokenStore
-
- reset() - Method in class org.eclipse.paho.client.mqttv3.internal.Token
-
- resetCounter() - Method in class org.eclipse.paho.client.mqttv3.internal.wire.CountingInputStream
-
Resets the counter to zero.
- resolveOldTokens(MqttException) - Method in class org.eclipse.paho.client.mqttv3.internal.ClientState
-
Called during shutdown to work out if there are any tokens still to be notified and waiters to be unblocked.
- restoreState() - Method in class org.eclipse.paho.client.mqttv3.internal.ClientState
-
Restores the state information from persistence.
- restoreToken(MqttPublish) - Method in class org.eclipse.paho.client.mqttv3.internal.CommsTokenStore
-
Restores a token after a client restart.
- run() - Method in class org.eclipse.paho.client.mqttv3.internal.CommsCallback
-
- run() - Method in class org.eclipse.paho.client.mqttv3.internal.CommsReceiver
-
Run loop to receive messages from the server.
- run() - Method in class org.eclipse.paho.client.mqttv3.internal.CommsSender
-
- running - Variable in class org.eclipse.paho.client.mqttv3.internal.CommsCallback
-