Package com.tccc.kos.commons.core.broker

Interface MessageBrokerCallback

public interface MessageBrokerCallback

Interface that defines the callback method that gets called when a broker message matching a subscribed topic is fired (published).

Example

 
  public class MyClass implements MessageBrokerCallback {

      // Instantiate the kOS system-wide message broker:
      @Autowired
      private MessageBroker messageBroker;

      public MyClass() {
          // Subscribe to a couple different topics:
          messageBroker.subscribe("mySession", "myTopic1", this);
          messageBroker.subscribe("mySession", "myTopic2", (msg) -> {
              // lambda version of using MessageBrokerCallback interface
              // to receive messages with a topic of "myTopic2"
              System.out.println("topic : " + msg->getTopic());
          });
      }

      // Implementation of the MessageBrokerCallback interface.
      // The kOS system calls this method when a message associated
      // with either "myTopic1" is published.
      @Override
      public void onMessage(MessageData msg) {
          System.out.println("topic : " + msg->getTopic());
      }
  }
 
 

Since:

1.0

Version:

2022-08-30

See Also:

• MessageBroker
• MessageData

Method Summary

Modifier and Type	Method	Description
void	onMessage(MessageData msgData)	This method is called when a broker message matching a subscribed topic is found.

Method Details

onMessage

void onMessage(MessageData msgData)

This method is called when a broker message matching a subscribed topic is found.

Parameters:

msgData - the message data