Package com.scaleoutsoftware.digitaltwin.datasource.aws

Class AwsIotObservingSubscriber

  • All Implemented Interfaces:
    com.scaleout.client.caching.PostedEventHandler<java.lang.String>, java.io.Serializable, java.util.Observer
    public class AwsIotObservingSubscriber
extends java.lang.Object
implements com.scaleout.client.caching.PostedEventHandler<java.lang.String>, java.io.Serializable, java.util.Observer
    The AwsIotObservingSubscriber handles establishing new connections with AWS IoT core and reposting messages from AWS IoT core to established DigitalTwins.
    See Also:
    Serialized Form

    • Method Summary

      Modifier and Type Method Description
      void onMessage​(java.lang.String key, com.scaleout.client.caching.EventPayload eventPayload)  
      void update​(java.util.Observable o, java.lang.Object arg)
      Called when the SOSS store membership changes and we need to reevaluate our AWS IoT Core connections.

      • Methods inherited from class java.lang.Object

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

    • Method Detail

      • update

        public void update​(java.util.Observable o,
                   java.lang.Object arg)
        Called when the SOSS store membership changes and we need to reevaluate our AWS IoT Core connections.
        Specified by:
        update in interface java.util.Observer
        Parameters:
        o - the observable that called update (MembershipPollingThread)
        arg - the HostToPartitionMapping

      • onMessage

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