SubscriptionsManager constructor
SubscriptionsManager(
- IMqttConnectionHandler? connectionHandler,
- PublishingManager? publishingManager,
- EventBus? _clientEventBus
Creates a new instance of a SubscriptionsManager that uses the specified connection to manage subscriptions.
Implementation
SubscriptionsManager(
this.connectionHandler, this.publishingManager, this._clientEventBus) {
connectionHandler!
.registerForMessage(MqttMessageType.subscribeAck, confirmSubscription);
connectionHandler!
.registerForMessage(MqttMessageType.unsubscribeAck, confirmUnsubscribe);
// Start listening for published messages and re subscribe events.
_clientEventBus!.on<MessageReceived>().listen(publishMessageReceived);
_clientEventBus!.on<Resubscribe>().listen(_resubscribe);
}