PublishingManager constructor

PublishingManager(
  1. IMqttConnectionHandler? connectionHandler,
  2. 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);
}