- checkForActivity() - Method in class org.eclipse.paho.client.mqttv3.internal.ClientComms
-
- checkForActivity(IMqttActionListener) - Method in class org.eclipse.paho.client.mqttv3.internal.ClientComms
-
- checkForActivity(IMqttActionListener) - Method in class org.eclipse.paho.client.mqttv3.internal.ClientState
-
Check and send a ping if needed and check for ping timeout.
- checkPing(Object, IMqttActionListener) - Method in class org.eclipse.paho.client.mqttv3.MqttAsyncClient
-
- checkResult() - Method in class org.eclipse.paho.client.mqttv3.internal.Token
-
- CIPHERSUITES - Static variable in class org.eclipse.paho.client.mqttv3.internal.security.SSLSocketFactoryFactory
-
- 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
-
- clear() - Method in class org.eclipse.paho.client.mqttv3.persist.MqttDefaultFilePersistence
-
- clearPayload() - Method in class org.eclipse.paho.client.mqttv3.MqttMessage
-
Clears the payload, resetting it to be empty.
- CLIENTAUTH - Static variable in class org.eclipse.paho.client.mqttv3.internal.security.SSLSocketFactoryFactory
-
- 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.
- 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.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
-
- close() - Method in class org.eclipse.paho.client.mqttv3.persist.MqttDefaultFilePersistence
-
- 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(String, String, String) - Method in class org.eclipse.paho.client.mqttv3.logging.JSR47Logger
-
- config(String, String, String, Object[]) - Method in class org.eclipse.paho.client.mqttv3.logging.JSR47Logger
-
- config(String, String, String, Object[], Throwable) - Method in class org.eclipse.paho.client.mqttv3.logging.JSR47Logger
-
- CONFIG - Static variable in interface org.eclipse.paho.client.mqttv3.logging.Logger
-
CONFIG is a message level for static configuration messages.
- config(String, String, String) - 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, String, 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, String, 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.
- 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, boolean) - Constructor for class org.eclipse.paho.client.mqttv3.internal.ConnectActionListener
-
- connectComplete(MqttConnack, MqttException) - Method in class org.eclipse.paho.client.mqttv3.internal.ClientComms
-
- connectComplete(boolean, String) - Method in interface org.eclipse.paho.client.mqttv3.MqttCallbackExtended
-
Called when the connection to the server is completed successfully.
- 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
-
- containsKey(String) - Method in class org.eclipse.paho.client.mqttv3.persist.MqttDefaultFilePersistence
-
- 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
-
- createSocketFactory(String) - Method in class org.eclipse.paho.client.mqttv3.internal.security.SSLSocketFactoryFactory
-
Returns an SSL socket factory for the given configuration.
- 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
-