Package org.springframework.integration.mqtt.core

Interface ClientManager.DefaultMessageHandler<M>

Type Parameters:
M - the message type from the specific client implementation.
Enclosing interface:
ClientManager<T,C>
Functional Interface:
This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
@FunctionalInterface public static interface ClientManager.DefaultMessageHandler<M>
A contract for a default message handler on the messageArrived event from the client.
Since:
6.5.6
See Also:
  • MqttCallback.messageArrived(String, org.eclipse.paho.mqttv5.common.MqttMessage)
  • MqttCallback.messageArrived(String, org.eclipse.paho.client.mqttv3.MqttMessage)

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    messageArrived(String topic, M message)
    Called when the messageArrived is called from the client as a fallback message listener.

  • Method Details

    • messageArrived

      void messageArrived(String topic, M message)
      Called when the messageArrived is called from the client as a fallback message listener.
      Parameters:
      topic - the topic from which the message was received. Could be used in the target implementation to filter messages by topic.
      message - the received and unrouted MQTT message.