PublishingManager constructor
PublishingManager(
- IMqttConnectionHandler? connectionHandler,
- EventBus? _clientEventBus
Initializes a new instance of the PublishingManager class.
Implementation
PublishingManager(this.connectionHandler, this._clientEventBus) {
connectionHandler!.registerForMessage(
MqttMessageType.publishAck, handlePublishAcknowledgement);
connectionHandler!
.registerForMessage(MqttMessageType.publish, handlePublish);
connectionHandler!.registerForMessage(
MqttMessageType.publishComplete, handlePublishComplete);
connectionHandler!.registerForMessage(
MqttMessageType.publishRelease, handlePublishRelease);
connectionHandler!.registerForMessage(
MqttMessageType.publishReceived, handlePublishReceived);
}