publishMessageReceived method
Publish message received
Implementation
void publishMessageReceived(MessageReceived event) {
final topic = event.topic;
final msg = MqttReceivedMessage<MqttMessage>(topic.rawTopic, event.message);
_subscriptionNotifier.add([msg]);
}