- markComplete(MqttWireMessage, MqttException) - Method in class org.eclipse.paho.client.mqttv3.internal.Token
-
Mark the token as complete and ready for users to be notified.
- MAX_MSG_SIZE - Static variable in class org.eclipse.paho.client.mqttv3.internal.ClientDefaults
-
- MemoryPersistence - Class in org.eclipse.paho.client.mqttv3.persist
-
Persistence that uses memory
In cases where reliability is not required across client or device restarts memory this memory peristence can be
used.
- MemoryPersistence() - Constructor for class org.eclipse.paho.client.mqttv3.persist.MemoryPersistence
-
- message - Variable in class org.eclipse.paho.client.mqttv3.internal.Token
-
- MESSAGE_TYPE_CONNACK - Static variable in class org.eclipse.paho.client.mqttv3.internal.wire.MqttWireMessage
-
- MESSAGE_TYPE_CONNECT - Static variable in class org.eclipse.paho.client.mqttv3.internal.wire.MqttWireMessage
-
- MESSAGE_TYPE_DISCONNECT - Static variable in class org.eclipse.paho.client.mqttv3.internal.wire.MqttWireMessage
-
- MESSAGE_TYPE_PINGREQ - Static variable in class org.eclipse.paho.client.mqttv3.internal.wire.MqttWireMessage
-
- MESSAGE_TYPE_PINGRESP - Static variable in class org.eclipse.paho.client.mqttv3.internal.wire.MqttWireMessage
-
- MESSAGE_TYPE_PUBACK - Static variable in class org.eclipse.paho.client.mqttv3.internal.wire.MqttWireMessage
-
- MESSAGE_TYPE_PUBCOMP - Static variable in class org.eclipse.paho.client.mqttv3.internal.wire.MqttWireMessage
-
- MESSAGE_TYPE_PUBLISH - Static variable in class org.eclipse.paho.client.mqttv3.internal.wire.MqttWireMessage
-
- MESSAGE_TYPE_PUBREC - Static variable in class org.eclipse.paho.client.mqttv3.internal.wire.MqttWireMessage
-
- MESSAGE_TYPE_PUBREL - Static variable in class org.eclipse.paho.client.mqttv3.internal.wire.MqttWireMessage
-
- MESSAGE_TYPE_SUBACK - Static variable in class org.eclipse.paho.client.mqttv3.internal.wire.MqttWireMessage
-
- MESSAGE_TYPE_SUBSCRIBE - Static variable in class org.eclipse.paho.client.mqttv3.internal.wire.MqttWireMessage
-
- MESSAGE_TYPE_UNSUBACK - Static variable in class org.eclipse.paho.client.mqttv3.internal.wire.MqttWireMessage
-
- MESSAGE_TYPE_UNSUBSCRIBE - Static variable in class org.eclipse.paho.client.mqttv3.internal.wire.MqttWireMessage
-
- messageArrived(MqttPublish) - Method in class org.eclipse.paho.client.mqttv3.internal.CommsCallback
-
This method is called when a message arrives on a topic.
- messageArrived(String, MqttMessage) - Method in interface org.eclipse.paho.client.mqttv3.MqttCallback
-
This method is called when a message arrives from the server.
- MessageCatalog - Class in org.eclipse.paho.client.mqttv3.internal
-
Catalog of human readable error messages.
- MessageCatalog() - Constructor for class org.eclipse.paho.client.mqttv3.internal.MessageCatalog
-
- MicroEJInternalLoggerFactory - Class in org.eclipse.paho.client.mqttv3.logging
-
- MicroEJInternalLoggerFactory() - Constructor for class org.eclipse.paho.client.mqttv3.logging.MicroEJInternalLoggerFactory
-
- MicroEJNetworkModuleFactory - Class in org.eclipse.paho.client.mqttv3.internal
-
- MicroEJNetworkModuleFactory() - Constructor for class org.eclipse.paho.client.mqttv3.internal.MicroEJNetworkModuleFactory
-
- MicroEJSystemProperties - Class in org.eclipse.paho.client.mqttv3.util
-
- MicroEJSystemProperties() - Constructor for class org.eclipse.paho.client.mqttv3.util.MicroEJSystemProperties
-
- MQTT_CLIENT_MSG_CAT - Static variable in class org.eclipse.paho.client.mqttv3.logging.LoggerFactory
-
Default message catalog.
- MQTT_VERSION_3_1 - Static variable in class org.eclipse.paho.client.mqttv3.MqttConnectOptions
-
- MQTT_VERSION_3_1_1 - Static variable in class org.eclipse.paho.client.mqttv3.MqttConnectOptions
-
- MQTT_VERSION_DEFAULT - Static variable in class org.eclipse.paho.client.mqttv3.MqttConnectOptions
-
The default MqttVersion is 3.1.1 first, dropping back to 3.1 if that fails
- MqttAck - Class in org.eclipse.paho.client.mqttv3.internal.wire
-
Abstract super-class of all acknowledgement messages.
- MqttAck(byte) - Constructor for class org.eclipse.paho.client.mqttv3.internal.wire.MqttAck
-
- MqttAsyncClient - Class in org.eclipse.paho.client.mqttv3
-
Lightweight client for talking to an MQTT server using non-blocking methods that allow an operation to run in the
background.
- MqttAsyncClient(String, String) - Constructor for class org.eclipse.paho.client.mqttv3.MqttAsyncClient
-
Create an MqttAsyncClient that is used to communicate with an MQTT server.
- MqttAsyncClient(String, String, MqttClientPersistence) - Constructor for class org.eclipse.paho.client.mqttv3.MqttAsyncClient
-
- MqttAsyncClient(String, String, MqttClientPersistence, MqttPingSender) - Constructor for class org.eclipse.paho.client.mqttv3.MqttAsyncClient
-
Create an MqttAsyncClient that is used to communicate with an MQTT server.
- MqttCallback - Interface in org.eclipse.paho.client.mqttv3
-
Enables an application to be notified when asynchronous events related to the client occur.
- MqttClient - Class in org.eclipse.paho.client.mqttv3
-
Lightweight client for talking to an MQTT server using methods that block until an operation completes.
- MqttClient(String, String) - Constructor for class org.eclipse.paho.client.mqttv3.MqttClient
-
Create an MqttClient that can be used to communicate with an MQTT server.
- MqttClient(String, String, MqttClientPersistence) - Constructor for class org.eclipse.paho.client.mqttv3.MqttClient
-
Create an MqttClient that can be used to communicate with an MQTT server.
- MqttClientPersistence - Interface in org.eclipse.paho.client.mqttv3
-
Represents a persistent data store, used to store outbound and inbound messages while they are in flight, enabling
delivery to the QoS specified.
- MqttConnack - Class in org.eclipse.paho.client.mqttv3.internal.wire
-
An on-the-wire representation of an MQTT CONNACK.
- MqttConnack(byte, byte[]) - Constructor for class org.eclipse.paho.client.mqttv3.internal.wire.MqttConnack
-
- MqttConnect - Class in org.eclipse.paho.client.mqttv3.internal.wire
-
An on-the-wire representation of an MQTT CONNECT message.
- MqttConnect(byte, byte[]) - Constructor for class org.eclipse.paho.client.mqttv3.internal.wire.MqttConnect
-
Constructor for an on the wire MQTT connect message
- MqttConnect(String, int, boolean, int, String, char[], MqttMessage, String) - Constructor for class org.eclipse.paho.client.mqttv3.internal.wire.MqttConnect
-
- MqttConnectOptions - Class in org.eclipse.paho.client.mqttv3
-
Holds the set of options that control how the client connects to a server.
- MqttConnectOptions() - Constructor for class org.eclipse.paho.client.mqttv3.MqttConnectOptions
-
Constructs a new MqttConnectOptions
object using the default values.
- MqttDeliveryToken - Class in org.eclipse.paho.client.mqttv3
-
Provides a mechanism to track the delivery progress of a message.
- MqttDeliveryToken() - Constructor for class org.eclipse.paho.client.mqttv3.MqttDeliveryToken
-
- MqttDeliveryToken(String) - Constructor for class org.eclipse.paho.client.mqttv3.MqttDeliveryToken
-
- MqttDisconnect - Class in org.eclipse.paho.client.mqttv3.internal.wire
-
An on-the-wire representation of an MQTT DISCONNECT message.
- MqttDisconnect() - Constructor for class org.eclipse.paho.client.mqttv3.internal.wire.MqttDisconnect
-
- MqttDisconnect(byte, byte[]) - Constructor for class org.eclipse.paho.client.mqttv3.internal.wire.MqttDisconnect
-
- MqttException - Exception in org.eclipse.paho.client.mqttv3
-
Thrown if an error occurs communicating with the server.
- MqttException(int) - Constructor for exception org.eclipse.paho.client.mqttv3.MqttException
-
Constructs a new MqttException
with the specified code as the underlying reason.
- MqttException(Throwable) - Constructor for exception org.eclipse.paho.client.mqttv3.MqttException
-
Constructs a new MqttException
with the specified Throwable
as the underlying reason.
- MqttException(int, Throwable) - Constructor for exception org.eclipse.paho.client.mqttv3.MqttException
-
Constructs a new MqttException
with the specified Throwable
as the underlying reason.
- MqttInputStream - Class in org.eclipse.paho.client.mqttv3.internal.wire
-
An MqttInputStream
lets applications read instances of MqttWireMessage
.
- MqttInputStream(ClientState, InputStream) - Constructor for class org.eclipse.paho.client.mqttv3.internal.wire.MqttInputStream
-
- MqttMessage - Class in org.eclipse.paho.client.mqttv3
-
An MQTT message holds the application payload and options specifying how the message is to be delivered The message
includes a "payload" (the body of the message) represented as a byte[].
- MqttMessage() - Constructor for class org.eclipse.paho.client.mqttv3.MqttMessage
-
Constructs a message with an empty payload, and all other values set to defaults.
- MqttMessage(byte[]) - Constructor for class org.eclipse.paho.client.mqttv3.MqttMessage
-
Constructs a message with the specified byte array as a payload, and all other values set to defaults.
- MqttOutputStream - Class in org.eclipse.paho.client.mqttv3.internal.wire
-
An MqttOutputStream
lets applications write instances of MqttWireMessage
.
- MqttOutputStream(ClientState, OutputStream) - Constructor for class org.eclipse.paho.client.mqttv3.internal.wire.MqttOutputStream
-
- MqttPersistable - Interface in org.eclipse.paho.client.mqttv3
-
- MqttPersistableWireMessage - Class in org.eclipse.paho.client.mqttv3.internal.wire
-
- MqttPersistableWireMessage(byte) - Constructor for class org.eclipse.paho.client.mqttv3.internal.wire.MqttPersistableWireMessage
-
- MqttPersistenceException - Exception in org.eclipse.paho.client.mqttv3
-
This exception is thrown by the implementor of the persistence interface if there is a problem reading or writing
persistent data.
- MqttPersistenceException() - Constructor for exception org.eclipse.paho.client.mqttv3.MqttPersistenceException
-
Constructs a new MqttPersistenceException
- MqttPersistenceException(int) - Constructor for exception org.eclipse.paho.client.mqttv3.MqttPersistenceException
-
Constructs a new MqttPersistenceException
with the specified code as the underlying reason.
- MqttPersistenceException(Throwable) - Constructor for exception org.eclipse.paho.client.mqttv3.MqttPersistenceException
-
Constructs a new MqttPersistenceException
with the specified Throwable
as the
underlying reason.
- MqttPersistenceException(int, Throwable) - Constructor for exception org.eclipse.paho.client.mqttv3.MqttPersistenceException
-
Constructs a new MqttPersistenceException
with the specified Throwable
as the
underlying reason.
- MqttPersistentData - Class in org.eclipse.paho.client.mqttv3.internal
-
- MqttPersistentData(String, byte[], int, int, byte[], int, int) - Constructor for class org.eclipse.paho.client.mqttv3.internal.MqttPersistentData
-
Construct a data object to pass across the MQTT client persistence interface.
- MqttPingReq - Class in org.eclipse.paho.client.mqttv3.internal.wire
-
An on-the-wire representation of an MQTT PINGREQ message.
- MqttPingReq() - Constructor for class org.eclipse.paho.client.mqttv3.internal.wire.MqttPingReq
-
- MqttPingReq(byte, byte[]) - Constructor for class org.eclipse.paho.client.mqttv3.internal.wire.MqttPingReq
-
- MqttPingResp - Class in org.eclipse.paho.client.mqttv3.internal.wire
-
An on-the-wire representation of an MQTT PINGRESP.
- MqttPingResp(byte, byte[]) - Constructor for class org.eclipse.paho.client.mqttv3.internal.wire.MqttPingResp
-
- MqttPingSender - Interface in org.eclipse.paho.client.mqttv3
-
Represents an object used to send ping packet to MQTT broker every keep alive interval.
- MqttPubAck - Class in org.eclipse.paho.client.mqttv3.internal.wire
-
An on-the-wire representation of an MQTT PUBACK message.
- MqttPubAck(byte, byte[]) - Constructor for class org.eclipse.paho.client.mqttv3.internal.wire.MqttPubAck
-
- MqttPubAck(MqttPublish) - Constructor for class org.eclipse.paho.client.mqttv3.internal.wire.MqttPubAck
-
- MqttPubComp - Class in org.eclipse.paho.client.mqttv3.internal.wire
-
An on-the-wire representation of an MQTT PUBCOMP message.
- MqttPubComp(byte, byte[]) - Constructor for class org.eclipse.paho.client.mqttv3.internal.wire.MqttPubComp
-
- MqttPubComp(MqttPublish) - Constructor for class org.eclipse.paho.client.mqttv3.internal.wire.MqttPubComp
-
- MqttPubComp(int) - Constructor for class org.eclipse.paho.client.mqttv3.internal.wire.MqttPubComp
-
- MqttPublish - Class in org.eclipse.paho.client.mqttv3.internal.wire
-
An on-the-wire representation of an MQTT SEND message.
- MqttPublish(String, MqttMessage) - Constructor for class org.eclipse.paho.client.mqttv3.internal.wire.MqttPublish
-
- MqttPublish(byte, byte[]) - Constructor for class org.eclipse.paho.client.mqttv3.internal.wire.MqttPublish
-
Constructs a new MqttPublish object.
- MqttPubRec - Class in org.eclipse.paho.client.mqttv3.internal.wire
-
An on-the-wire representation of an MQTT PUBREC message.
- MqttPubRec(byte, byte[]) - Constructor for class org.eclipse.paho.client.mqttv3.internal.wire.MqttPubRec
-
- MqttPubRec(MqttPublish) - Constructor for class org.eclipse.paho.client.mqttv3.internal.wire.MqttPubRec
-
- MqttPubRel - Class in org.eclipse.paho.client.mqttv3.internal.wire
-
An on-the-wire representation of an MQTT PUBREL message.
- MqttPubRel(MqttPubRec) - Constructor for class org.eclipse.paho.client.mqttv3.internal.wire.MqttPubRel
-
Createa a pubrel message based on a pubrec
- MqttPubRel(byte, byte[]) - Constructor for class org.eclipse.paho.client.mqttv3.internal.wire.MqttPubRel
-
Creates a pubrel based on a pubrel set of bytes read fro the network
- MqttReceivedMessage - Class in org.eclipse.paho.client.mqttv3.internal.wire
-
- MqttReceivedMessage() - Constructor for class org.eclipse.paho.client.mqttv3.internal.wire.MqttReceivedMessage
-
- MqttSecurityException - Exception in org.eclipse.paho.client.mqttv3
-
Thrown when a client is not authorized to perform an operation, or if there is a problem with the security
configuration.
- MqttSecurityException(int) - Constructor for exception org.eclipse.paho.client.mqttv3.MqttSecurityException
-
Constructs a new MqttSecurityException
with the specified code as the underlying reason.
- MqttSecurityException(Throwable) - Constructor for exception org.eclipse.paho.client.mqttv3.MqttSecurityException
-
Constructs a new MqttSecurityException
with the specified Throwable
as the underlying
reason.
- MqttSecurityException(int, Throwable) - Constructor for exception org.eclipse.paho.client.mqttv3.MqttSecurityException
-
Constructs a new MqttSecurityException
with the specified code and Throwable
as the
underlying reason.
- MqttSuback - Class in org.eclipse.paho.client.mqttv3.internal.wire
-
An on-the-wire representation of an MQTT SUBACK.
- MqttSuback(byte, byte[]) - Constructor for class org.eclipse.paho.client.mqttv3.internal.wire.MqttSuback
-
- MqttSubscribe - Class in org.eclipse.paho.client.mqttv3.internal.wire
-
An on-the-wire representation of an MQTT SUBSCRIBE message.
- MqttSubscribe(byte, byte[]) - Constructor for class org.eclipse.paho.client.mqttv3.internal.wire.MqttSubscribe
-
Constructor for an on the wire MQTT subscribe message
- MqttSubscribe(String[], int[]) - Constructor for class org.eclipse.paho.client.mqttv3.internal.wire.MqttSubscribe
-
Constructor for an on the wire MQTT subscribe message
- MqttToken - Class in org.eclipse.paho.client.mqttv3
-
Provides a mechanism for tracking the completion of an asynchronous action.
- MqttToken() - Constructor for class org.eclipse.paho.client.mqttv3.MqttToken
-
- MqttToken(String) - Constructor for class org.eclipse.paho.client.mqttv3.MqttToken
-
- MqttTopic - Class in org.eclipse.paho.client.mqttv3
-
Represents a topic destination, used for publish/subscribe messaging.
- MqttTopic(String, ClientComms) - Constructor for class org.eclipse.paho.client.mqttv3.MqttTopic
-
- MqttUnsubAck - Class in org.eclipse.paho.client.mqttv3.internal.wire
-
An on-the-wire representation of an MQTT UNSUBACK.
- MqttUnsubAck(byte, byte[]) - Constructor for class org.eclipse.paho.client.mqttv3.internal.wire.MqttUnsubAck
-
- MqttUnsubscribe - Class in org.eclipse.paho.client.mqttv3.internal.wire
-
An on-the-wire representation of an MQTT UNSUBSCRIBE message.
- MqttUnsubscribe(String[]) - Constructor for class org.eclipse.paho.client.mqttv3.internal.wire.MqttUnsubscribe
-
Constructs an MqttUnsubscribe
- MqttUnsubscribe(byte, byte[]) - Constructor for class org.eclipse.paho.client.mqttv3.internal.wire.MqttUnsubscribe
-
Constructor for an on the wire MQTT un-subscribe message
- MqttWireMessage - Class in org.eclipse.paho.client.mqttv3.internal.wire
-
An on-the-wire representation of an MQTT message.
- MqttWireMessage(byte) - Constructor for class org.eclipse.paho.client.mqttv3.internal.wire.MqttWireMessage
-
- msgId - Variable in class org.eclipse.paho.client.mqttv3.internal.wire.MqttWireMessage
-
- MULTI_LEVEL_WILDCARD - Static variable in class org.eclipse.paho.client.mqttv3.MqttTopic
-
Multi-level wildcard The number sign (#) is a wildcard character that matches any number of levels within a
topic.
- MULTI_LEVEL_WILDCARD_PATTERN - Static variable in class org.eclipse.paho.client.mqttv3.MqttTopic
-
Multi-level wildcard pattern(/#)
- MultiByteArrayInputStream - Class in org.eclipse.paho.client.mqttv3.internal.wire
-
- MultiByteArrayInputStream(byte[], int, int, byte[], int, int) - Constructor for class org.eclipse.paho.client.mqttv3.internal.wire.MultiByteArrayInputStream
-
- MultiByteInteger - Class in org.eclipse.paho.client.mqttv3.internal.wire
-
Represents a Multi-Byte Integer (MBI), as defined by the MQTT V3 specification.
- MultiByteInteger(long) - Constructor for class org.eclipse.paho.client.mqttv3.internal.wire.MultiByteInteger
-
- MultiByteInteger(long, int) - Constructor for class org.eclipse.paho.client.mqttv3.internal.wire.MultiByteInteger
-