MqttSubscriptionManager constructor
MqttSubscriptionManager(
- dynamic _connectionHandler,
- dynamic _clientEventBus
Creates a new instance of a SubscriptionsManager that uses the specified connection to manage subscriptions.
Implementation
MqttSubscriptionManager(this._connectionHandler, this._clientEventBus) {
_connectionHandler.registerForMessage(
MqttMessageType.subscribeAck, confirmSubscription);
_connectionHandler.registerForMessage(
MqttMessageType.unsubscribeAck, confirmUnsubscribe);
// Start listening for published messages
_clientEventBus.on<MqttMessageReceived>().listen(publishMessageReceived);
_clientEventBus.on<MqttResubscribe>().listen(_resubscribe);
}