-
authentication
→ Stream<MqttAuthenticateMessage>?
-
Authenticate message stream. A received authenticate message is
added to this stream.
Attach listeners only after connect has been called.
no setterinherited
-
authenticationManager
↔ MqttAuthenticationManager?
-
Handles everything to do with authentication messages.
getter/setter pairinherited
-
autoReconnect
↔ bool
-
Auto reconnect, the client will auto reconnect if set true.
getter/setter pairinherited
-
clientEventBus
↔ EventBus?
-
The event bus
getter/setter pairinherited
-
clientIdentifier
↔ String
-
Client identifier
getter/setter pairinherited
-
connectionHandler
↔ dynamic
-
The Handler that is managing the connection to the remote server.
getter/setter pairinherited
-
connectionMessage
↔ MqttConnectMessage?
-
The connection message to use to override the default
getter/setter pairinherited
-
connectionState
→ MqttConnectionState?
-
Gets the current connection state of the Mqtt Client.
Will be removed, use connectionStatus
no setterinherited
-
connectionStatus
→ MqttConnectionStatus?
-
Gets the current connection status of the Mqtt Client.
This is the connection state as above also with the broker return code.
Set after every connection attempt.
no setterinherited
-
disconnectOnNoResponsePeriod
↔ int
-
The period of time to wait if the broker does not respond to a ping request
from keep alive processing, in seconds.
If this time period is exceeded the client is forcibly disconnected.
The default is 0, which disables this functionality.
Thi setting has no effect if keep alive is disabled.
getter/setter pairinherited
-
hashCode
→ int
-
The hash code for this object.
no setterinherited
-
instantiationCorrect
↔ bool
-
Incorrect instantiation protection
getter/setter pairinherited
-
keepAlive
↔ MqttConnectionKeepAlive?
-
Handles the connection management while idle.
getter/setter pairinherited
-
keepAlivePeriod
↔ int
-
Keep alive period, seconds.
The default is 0 which disables the keep alive mechanism.
To enable the keep alive mechanism set this to a value greater than 0.
getter/setter pairinherited
-
maxConnectionAttempts
→ int
-
Max connection attempts
final
-
onAutoReconnect
↔ AutoReconnectCallback?
-
Auto reconnect callback, if auto reconnect is selected this callback will
be called before auto reconnect processing is invoked to allow the user to
perform any pre auto reconnect actions.
getter/setter pairinherited
-
onAutoReconnected
↔ AutoReconnectCompleteCallback?
-
Auto reconnected callback, if auto reconnect is selected this callback will
be called after auto reconnect processing is completed to allow the user to
perform any post auto reconnect actions.
getter/setter pairinherited
-
onBadCertificate
↔ bool Function(dynamic certificate)?
-
Callback function to handle bad certificate. if true, ignore the error.
getter/setter pair
-
onConnected
↔ ConnectCallback?
-
Client connect callback, called on successful connect
getter/setter pairinherited
-
onDisconnected
↔ DisconnectCallback?
-
Client disconnect callback, called on unsolicited disconnect.
This will not be called even if set if [autoReconnect} is set,instead
AutoReconnectCallback will be called.
getter/setter pairinherited
-
onFailedConnectionAttempt
↔ FailedConnectionAttemptCallback?
-
Failed Connection attempt callback.
Called on every failed connection attempt, if maxConnectionAttempts is
set to 5 say this will be called 5 times if the connection fails,
one for every failed attempt. Note this is never called
if autoReconnect is set.
If autoReconnect is set, the MqttNoConnectionException
is not raised if this callback is supplied.
getter/setter pairinherited
-
onSubscribed
↔ SubscribeCallback?
-
On subscribed
getter/setter pairinherited
-
onSubscribeFail
↔ SubscribeFailCallback?
-
On subscribed fail
getter/setter pairinherited
-
onUnsubscribed
↔ UnsubscribeCallback?
-
On unsubscribed
getter/setter pairinherited
-
pongCallback
↔ PongCallback?
-
The ping received callback
getter/setter pairinherited
-
port
↔ int?
-
Port number
getter/setter pairinherited
-
published
→ Stream<MqttPublishMessage>?
-
Published message stream. A publish message is added to this
stream on completion of the message publishing protocol for a Qos level.
Attach listeners only after connect has been called.
no setterinherited
-
publishingManager
↔ MqttPublishingManager?
-
Handles everything to do with publication management.
getter/setter pairinherited
-
resubscribeOnAutoReconnect
↔ bool
-
Re subscribe on auto reconnect.
Auto reconnect will perform automatic re subscription of existing confirmed subscriptions
unless this is set to false.
In this case the caller must perform their own re subscriptions manually using
unsubscribe,
subscribe and resubscribe as needed from the appropriate callbacks.
getter/setter pairinherited
-
runtimeType
→ Type
-
A representation of the runtime type of the object.
no setterinherited
-
secure
↔ bool
-
If set use a secure connection, note TCP only, do not use for
secure websockets(wss).
getter/setter pair
-
securityContext
↔ SecurityContext
-
The security context for secure usage
getter/setter pair
-
server
↔ String
-
Server name
getter/setter pairinherited
-
socketOptions
↔ List<RawSocketOption>
-
The client supports the setting of both integer and boolean raw socket options
as supported by the Dart IO library RawSocketOption class.
Please consult the documentation for the above class before using this.
getter/setter pair
-
subscriptionsManager
↔ MqttSubscriptionManager?
-
The subscriptions manager responsible for tracking subscriptions.
getter/setter pairinherited
-
updates
→ Stream<List<MqttReceivedMessage<MqttMessage>>>
-
The stream on which all subscribed topic updates are published to
no setterinherited
-
useAlternateWebSocketImplementation
↔ bool
-
If set use the alternate websocket implementation
getter/setter pair
-
useWebSocket
↔ bool
-
If set use a websocket connection, otherwise use the default TCP one
getter/setter pair
-
websocketProtocols
← List<String>
-
User definable websocket protocols. Use this for non default websocket
protocols only if your broker needs this. There are two defaults in
MqttWsConnection class, the single protocol is the default. Some brokers
will not accept a list and only expect a single protocol identifier,
in this case use the single protocol default. You can supply your own
list, or to disable this entirely set the protocols to an
empty list , i.e [].
no getterinherited
-
websocketProtocolString
↔ List<String>?
-
getter/setter pairinherited
