- Character_isHighSurrogate(char) - Static method in class org.eclipse.paho.client.mqttv3.util.Strings
-
- checkForActivity() - Method in class org.eclipse.paho.client.mqttv3.internal.ClientComms
-
- checkForActivity() - Method in class org.eclipse.paho.client.mqttv3.internal.ClientState
-
Check and send a ping if needed and check for ping timeout.
- checkMutable() - Method in class org.eclipse.paho.client.mqttv3.MqttMessage
-
- checkPing(Object, IMqttActionListener) - Method in class org.eclipse.paho.client.mqttv3.MqttAsyncClient
-
- checkQuiesceLock() - Method in class org.eclipse.paho.client.mqttv3.internal.ClientState
-
- checkResult() - Method in class org.eclipse.paho.client.mqttv3.internal.Token
-
- CLEAN_SESSION_DEFAULT - Static variable in class org.eclipse.paho.client.mqttv3.MqttConnectOptions
-
The default clean session setting if one is not specified
- clear() - Method in class org.eclipse.paho.client.mqttv3.internal.CommsTokenStore
-
Empties the token store without notifying any of the tokens.
- clear() - Method in interface org.eclipse.paho.client.mqttv3.MqttClientPersistence
-
Clears persistence, so that it no longer contains any persisted data.
- clear() - Method in class org.eclipse.paho.client.mqttv3.persist.MemoryPersistence
-
- clearPayload() - Method in class org.eclipse.paho.client.mqttv3.MqttMessage
-
Clears the payload, resetting it to be empty.
- clearState() - Method in class org.eclipse.paho.client.mqttv3.internal.ClientState
-
- ClientComms - Class in org.eclipse.paho.client.mqttv3.internal
-
Handles client communications with the server.
- ClientComms(IMqttAsyncClient, MqttClientPersistence, MqttPingSender) - Constructor for class org.eclipse.paho.client.mqttv3.internal.ClientComms
-
Creates a new ClientComms object, using the specified module to handle the network calls.
- ClientDefaults - Class in org.eclipse.paho.client.mqttv3.internal
-
- ClientDefaults() - Constructor for class org.eclipse.paho.client.mqttv3.internal.ClientDefaults
-
- ClientState - Class in org.eclipse.paho.client.mqttv3.internal
-
The core of the client, which holds the state information for pending and in-flight messages.
- ClientState(MqttClientPersistence, CommsTokenStore, CommsCallback, ClientComms, MqttPingSender) - Constructor for class org.eclipse.paho.client.mqttv3.internal.ClientState
-
- close() - Method in interface org.eclipse.paho.client.mqttv3.IMqttAsyncClient
-
Close the client Releases all resource associated with the client.
- close() - Method in interface org.eclipse.paho.client.mqttv3.IMqttClient
-
Close the client Releases all resource associated with the client.
- close() - Method in class org.eclipse.paho.client.mqttv3.internal.ClientComms
-
Close and tidy up.
- close() - Method in class org.eclipse.paho.client.mqttv3.internal.ClientState
-
Tidy up - ensure that tokens are released as they are maintained over a disconnect / connect cycle.
- close() - Method in class org.eclipse.paho.client.mqttv3.internal.wire.MqttInputStream
-
- close() - Method in class org.eclipse.paho.client.mqttv3.internal.wire.MqttOutputStream
-
- close() - Method in class org.eclipse.paho.client.mqttv3.MqttAsyncClient
-
- close() - Method in class org.eclipse.paho.client.mqttv3.MqttClient
-
- close() - Method in interface org.eclipse.paho.client.mqttv3.MqttClientPersistence
-
Close the persistent store that was previously opened.
- close() - Method in class org.eclipse.paho.client.mqttv3.persist.MemoryPersistence
-
- comms - Variable in class org.eclipse.paho.client.mqttv3.MqttAsyncClient
-
- CommsCallback - Class in org.eclipse.paho.client.mqttv3.internal
-
Bridge between Receiver and the external API.
- CommsReceiver - Class in org.eclipse.paho.client.mqttv3.internal
-
Receives MQTT packets from the server.
- CommsReceiver(ClientComms, ClientState, CommsTokenStore, InputStream) - Constructor for class org.eclipse.paho.client.mqttv3.internal.CommsReceiver
-
- CommsSender - Class in org.eclipse.paho.client.mqttv3.internal
-
- CommsSender(ClientComms, ClientState, CommsTokenStore, OutputStream) - Constructor for class org.eclipse.paho.client.mqttv3.internal.CommsSender
-
- CommsTokenStore - Class in org.eclipse.paho.client.mqttv3.internal
-
Provides a "token" based system for storing and tracking actions across multiple threads.
- CommsTokenStore(String) - Constructor for class org.eclipse.paho.client.mqttv3.internal.CommsTokenStore
-
- CONFIG - Static variable in interface org.eclipse.paho.client.mqttv3.logging.Logger
-
CONFIG is a message level for static configuration messages.
- config(String, String, int) - Method in interface org.eclipse.paho.client.mqttv3.logging.Logger
-
Log a message, specifying source class and method, if the logger is currently enabled for the given message
level.
- config(String, String, int, Object[]) - Method in interface org.eclipse.paho.client.mqttv3.logging.Logger
-
Log a message, specifying source class and method, with an array of object arguments, if the logger is currently
enabled for the given message level.
- config(String, String, int, Object[], Throwable) - Method in interface org.eclipse.paho.client.mqttv3.logging.Logger
-
Log a message, specifying source class and method, with an array of object arguments and a throwable, if the
logger is currently enabled for the given message level.
- config(String, String, int) - Method in class org.eclipse.paho.client.mqttv3.logging.MicroEJInternalLoggerFactory
-
- config(String, String, int, Object[]) - Method in class org.eclipse.paho.client.mqttv3.logging.MicroEJInternalLoggerFactory
-
- config(String, String, int, Object[], Throwable) - Method in class org.eclipse.paho.client.mqttv3.logging.MicroEJInternalLoggerFactory
-
- connect() - Method in interface org.eclipse.paho.client.mqttv3.IMqttAsyncClient
-
Connects to an MQTT server using the default options.
- connect(MqttConnectOptions) - Method in interface org.eclipse.paho.client.mqttv3.IMqttAsyncClient
-
Connects to an MQTT server using the provided connect options.
- connect(Object, IMqttActionListener) - Method in interface org.eclipse.paho.client.mqttv3.IMqttAsyncClient
-
Connects to an MQTT server using the default options.
- connect(MqttConnectOptions, Object, IMqttActionListener) - Method in interface org.eclipse.paho.client.mqttv3.IMqttAsyncClient
-
Connects to an MQTT server using the specified options.
- connect() - Method in interface org.eclipse.paho.client.mqttv3.IMqttClient
-
Connects to an MQTT server using the default options.
- connect(MqttConnectOptions) - Method in interface org.eclipse.paho.client.mqttv3.IMqttClient
-
Connects to an MQTT server using the specified options.
- connect(MqttConnectOptions, MqttToken) - Method in class org.eclipse.paho.client.mqttv3.internal.ClientComms
-
Sends a connect message and waits for an ACK or NACK.
- connect() - Method in class org.eclipse.paho.client.mqttv3.internal.ConnectActionListener
-
Start the connect processing
- connect(Object, IMqttActionListener) - Method in class org.eclipse.paho.client.mqttv3.MqttAsyncClient
-
- connect() - Method in class org.eclipse.paho.client.mqttv3.MqttAsyncClient
-
- connect(MqttConnectOptions) - Method in class org.eclipse.paho.client.mqttv3.MqttAsyncClient
-
- connect(MqttConnectOptions, Object, IMqttActionListener) - Method in class org.eclipse.paho.client.mqttv3.MqttAsyncClient
-
- connect() - Method in class org.eclipse.paho.client.mqttv3.MqttClient
-
- connect(MqttConnectOptions) - Method in class org.eclipse.paho.client.mqttv3.MqttClient
-
- ConnectActionListener - Class in org.eclipse.paho.client.mqttv3.internal
-
This class handles the connection of the AsyncClient to one of the available URLs.
- ConnectActionListener(MqttAsyncClient, MqttClientPersistence, ClientComms, MqttConnectOptions, MqttToken, Object, IMqttActionListener) - Constructor for class org.eclipse.paho.client.mqttv3.internal.ConnectActionListener
-
- connectComplete(MqttConnack, MqttException) - Method in class org.eclipse.paho.client.mqttv3.internal.ClientComms
-
- connected() - Method in class org.eclipse.paho.client.mqttv3.internal.ClientState
-
Called when the client has successfully connected to the broker
- CONNECTION_TIMEOUT_DEFAULT - Static variable in class org.eclipse.paho.client.mqttv3.MqttConnectOptions
-
The default connection timeout in seconds if one is not specified
- connectionLost(MqttException) - Method in class org.eclipse.paho.client.mqttv3.internal.CommsCallback
-
This method is called when the connection to the server is lost.
- connectionLost(Throwable) - Method in interface org.eclipse.paho.client.mqttv3.MqttCallback
-
This method is called when the connection to the server is lost.
- connectWithResult(MqttConnectOptions) - Method in interface org.eclipse.paho.client.mqttv3.IMqttClient
-
Connects to an MQTT server using the specified options.
- connectWithResult(MqttConnectOptions) - Method in class org.eclipse.paho.client.mqttv3.MqttClient
-
- containsAny(CharSequence, CharSequence) - Static method in class org.eclipse.paho.client.mqttv3.util.Strings
-
Checks if the CharSequence contains any character in the given set of characters.
- containsAny(CharSequence, char[]) - Static method in class org.eclipse.paho.client.mqttv3.util.Strings
-
Checks if the CharSequence contains any character in the given set of characters.
- containsKey(String) - Method in interface org.eclipse.paho.client.mqttv3.MqttClientPersistence
-
Returns whether or not data is persisted using the specified key.
- containsKey(String) - Method in class org.eclipse.paho.client.mqttv3.persist.MemoryPersistence
-
- count() - Method in class org.eclipse.paho.client.mqttv3.internal.CommsTokenStore
-
- CountingInputStream - Class in org.eclipse.paho.client.mqttv3.internal.wire
-
An input stream that counts the bytes read from it.
- CountingInputStream(InputStream) - Constructor for class org.eclipse.paho.client.mqttv3.internal.wire.CountingInputStream
-
Constructs a new CountingInputStream
wrapping the supplied input stream.
- countMatches(CharSequence, CharSequence) - Static method in class org.eclipse.paho.client.mqttv3.util.Strings
-
Counts how many times the substring appears in the larger string.
- createMqttException(int) - Static method in class org.eclipse.paho.client.mqttv3.internal.ExceptionHelper
-
- createMqttException(Throwable) - Static method in class org.eclipse.paho.client.mqttv3.internal.ExceptionHelper
-
- createNetworkModule(String, MqttConnectOptions, String) - Method in class org.eclipse.paho.client.mqttv3.internal.MicroEJNetworkModuleFactory
-
- createNetworkModule(String, MqttConnectOptions, String) - Method in interface org.eclipse.paho.client.mqttv3.internal.NetworkModuleFactory
-
Factory methods to create the correct network module, based on the supplied address URI.
- createNetworkModules(String, MqttConnectOptions) - Method in class org.eclipse.paho.client.mqttv3.MqttAsyncClient
-
Factory method to create an array of network modules, one for each of the supplied URIs
- createWireMessage(MqttPersistable) - Static method in class org.eclipse.paho.client.mqttv3.internal.wire.MqttWireMessage
-
- createWireMessage(byte[]) - Static method in class org.eclipse.paho.client.mqttv3.internal.wire.MqttWireMessage
-
- createWireMessage(int, byte[]) - Static method in class org.eclipse.paho.client.mqttv3.internal.wire.MqttWireMessage
-