mqtt_client
library
Classes
AsciiPayloadConverter
Converts string data to and from the MQTT wire format
AutoReconnect
Auto reconnect event
ConnectAckMessageAvailable
The connect acknowledge message available event raised by the Connection class
DisconnectOnNoMessageSent
Disconnect on sent message failed event
DisconnectOnNoPingResponse
Disconnect on keep alive on no ping response event
IMqttConnectionHandler
The connection handler interface class
IPublishingManager
Interface that defines how the publishing manager publishes
messages to the broker and how it passed on messages that are
received from the broker.
MessageAvailable
The message available event raised by the Connection class
MessageIdentifierDispenser
Message identifier handling
MessageReceived
Message recieved class for publishing
MqttByteBuffer
Utility class to allow stream like access to a sized byte buffer.
This class is in effect a cut-down implementation of the C# NET
System.IO class with Mqtt client specific extensions.
MqttCancellableAsyncSleep
Cancellable asynchronous sleep support class
MqttClient
A client class for interacting with MQTT Data Packets.
Do not instantiate this class directly, instead instantiate
either a MqttClientServer class or an MqttBrowserClient as needed.
This class now provides common functionality between server side
and web based clients.
MqttClientConnectionStatus
Records the status of the last connection attempt
MqttClientConstants
Library wide constants
MqttClientPayloadBuilder
Utility class to assist with the building of message topic payloads.
Implements the builder pattern, i.e. returns itself to allow chaining.
MqttClientTopicFilter
This class allows specific topics to be listened for. It essentially
acts as a bandpass filter for the topics you are interested in if
you subscribe to more than one topic or use wildcard topics.
Simply construct it, and listen to its message stream rather than
that of the client. Note this class will only filter valid receive topics
so if you filter on wildcard topics for instance, which you should only
subscribe to, it will always generate a no match.
MqttConnectAckMessage
Message that indicates a connection acknowledgement.
Implementation of the variable header for an MQTT ConnectAck message.
MqttConnectFlags
Represents the connect flags part of the MQTT Variable Header
MqttConnectionBase <T extends Object >
The MQTT client connection base class
MqttConnectionHandlerBase
This class provides shared connection functionality
to serverand browser connection handler implementations.
MqttConnectionKeepAlive
Implements keep alive functionality on the Mqtt Connection,
ensuring that the connection remains active according to the
keep alive seconds setting.
This class implements the keep alive by sending an MqttPingRequest
to the broker if a message has not been sent or received
within the keep alive period.
Optionally a disconnect on no response property can be set to force disconnect the client
if the broker does not respond to a ping request for a specified period of time.
MqttConnectMessage
An Mqtt message that is used to initiate a connection to a message broker.
MqttConnectPayload
Class that contains details related to an MQTT Connect messages payload.
Implementation of the variable header for an MQTT Connect message.
MqttDisconnectMessage
Implementation of an MQTT Disconnect Message.
MqttEncoding
Encoding implementation that can encode and decode strings
in the MQTT string format.
Represents the Fixed Header of an MQTT message.
MqttLogger
Library wide logging class
MqttMessage
Represents an MQTT message that contains a fixed header, variable
header and message body.
MqttMessageFactory
Factory for generating instances of MQTT Messages
MqttPayload
Represents the payload (Body) of an MQTT Message.
MqttPingRequestMessage
Implementation of an MQTT ping Request Message.
MqttPingResponseMessage
Implementation of an MQTT ping Request Message.
MqttPublishAckMessage
Implementation of an MQTT Publish Acknowledgement Message, used to ACK a
publish message that has it's QOS set to AtLeast or Exactly Once.
Implementation of the variable header for an MQTT Publish
Acknowledgement message.
MqttPublishCompleteMessage
Implementation of an MQTT Publish Complete Message.
Implementation of the variable header for an MQTT Publish Complete message.
MqttPublishMessage
Implementation of an MQTT Publish Message, used for publishing
telemetry data along a live MQTT stream.
MqttPublishPayload
Class that contains details related to an MQTT Connect messages payload
MqttPublishReceivedMessage
Implementation of an MQTT Publish Received Message.
Implementation of the variable header for an MQTT Publish Received message.
MqttPublishReleaseMessage
Implementation of an MQTT Publish Release Message.
Implementation of the variable header for an MQTT Publish Release message.
Implementation of the variable header for an MQTT Connect message.
MqttReceivedMessage <T >
Represents a MQTT message that has been received from a broker.
MqttSubscribeAckMessage
Implementation of an MQTT Subscribe Ack Message.
MqttSubscribeAckPayload
Class that contains details related to an MQTT Subscribe Ack
messages payload.
Implementation of the variable header for an MQTT Subscribe Ack message.
MqttSubscribeMessage
Implementation of an MQTT Subscribe Message.
MqttSubscribePayload
Class that contains details related to an MQTT Subscribe messages payload
Implementation of the variable header for an MQTT Subscribe message.
MqttUnsubscribeAckMessage
Implementation of an MQTT Unsubscribe Ack Message.
Implementation of the variable header for an MQTT Unsubscribe Ack message.
MqttUnsubscribeMessage
Implementation of an MQTT Unsubscribe Message.
MqttUnsubscribePayload
Class that contains details related to an MQTT Unsubscribe messages payload
Implementation of the variable header for an MQTT Unsubscribe message.
MqttUtilities
General library wide utilties
Represents the base class for the Variable Header portion
of some MQTT Messages.
PassthruPayloadConverter
Acts as a pass through for the raw data without doing any conversion.
PayloadConverter <T >
Interface that defines the methods and properties that must be provided
by classes that interpret and convert inbound and outbound
published message data.
Protocol
Protocol selection helper class, protocol defaults V3.1
PublicationTopic
Implementation of a Publication topic that performs additional validations
of messages that are published.
PublishingManager
Handles the logic and workflow surrounding the message publishing and receipt process.
ReadWrapper
State and logic used to read from the underlying network stream.
Resubscribe
Re subscribe event
Subscription
Entity that captures data related to an individual subscription
SubscriptionsManager
A class that can manage the topic subscription process.
SubscriptionTopic
Implementation of a Subscription topic that performs additional validations
of topics that are subscribed to.
Topic
Provides the base implementation of an MQTT topic.
