registerForMessage method

  1. @override
void registerForMessage(
  1. MqttMessageType msgType,
  2. MessageCallbackFunction? callback
)
override

Registers for the receipt of messages when they arrive.

Implementation

@override
void registerForMessage(
  MqttMessageType msgType,
  MessageCallbackFunction? callback,
) {
  messageProcessorRegistry[msgType] = callback;
}