Creates a new instance of the connection component.
The NATS connection pool object.
The connection resolver.
The logger.
The configuration options.
Topic subscriptions
Checks if connection is open
an error is connection is closed or null
otherwise.
Closes component and frees used resources.
(optional) transaction id to trace execution through call chain.
callback function that receives error or null no errors occured.
Configures component by passing configuration parameters.
configuration parameters to be set.
Creates a message queue. If connection doesn't support this function it exists without error.
the name of the queue to be created.
notifies about completion with error or null for success.
Deletes a message queue. If connection doesn't support this function it exists without error.
the name of the queue to be deleted.
notifies about completion with error or null for success.
Checks if the component is opened.
true if the component has been opened and false otherwise.
Opens the component.
(optional) transaction id to trace execution through call chain.
callback function that receives error or null no errors occured.
Publish a message to a specified topic
a topic name
a message to be published
publishing options
(optional) callback to receive notification on operation result
Reads a list of registered queue names. If connection doesn't support this function returnes an empty list.
Sets references to dependent components.
references to locate the component dependencies.
Subscribe to a topic
a topic name
subscription options
a message listener
(optional) callback to receive notification on operation result
Unsubscribe from a previously subscribed topic
a topic name
a message listener
(optional) callback to receive notification on operation result
Generated using TypeDoc
Connection to MQTT message broker.
MQTT is a popular light-weight protocol to communicate IoT devices.
Configuration parameters
References
*:logger:*:*:1.0
(optional) ILogger components to pass log messages*:counters:*:*:1.0
(optional) ICounters components to pass collected measurements*:discovery:*:*:1.0
(optional) IDiscovery services to resolve connections*:credential-store:*:*:1.0
(optional) Credential stores to resolve credentials[[MessageQueue]]
[[MessagingCapabilities]]