Package com.scaleoutsoftware.digitaltwin.datasource.kafka

Class ProducerObserver

  • All Implemented Interfaces:
    com.scaleout.client.caching.PostedEventHandler<java.lang.String>, java.io.Serializable
    public class ProducerObserver
extends java.lang.Object
implements com.scaleout.client.caching.PostedEventHandler<java.lang.String>, java.io.Serializable
    See Also:
    Serialized Form

    • Constructor Summary

      Constructors 
      Constructor Description
      ProducerObserver​(java.lang.String connectorName, java.util.Map<java.lang.String,​java.lang.String> modelToTopicConfigurations, java.util.Map<java.lang.String,​java.lang.Object> kafkaProperties)  

    • Method Summary

      Modifier and Type Method Description
      void onMessage​(java.lang.String key, com.scaleout.client.caching.EventPayload payload)  

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Constructor Detail

      • ProducerObserver

        public ProducerObserver​(java.lang.String connectorName,
                        java.util.Map<java.lang.String,​java.lang.String> modelToTopicConfigurations,
                        java.util.Map<java.lang.String,​java.lang.Object> kafkaProperties)

    • Method Detail

      • onMessage

        public void onMessage​(java.lang.String key,
                      com.scaleout.client.caching.EventPayload payload)
        Specified by:
        onMessage in interface com.scaleout.client.caching.PostedEventHandler<java.lang.String>