Package com.scaleoutsoftware.digitaltwin.datasource.aws

Class AwsIotMultiplexer

  • public class AwsIotMultiplexer
extends java.lang.Object
    The AwsIotMultiplexer handles incoming messages from AWS IoT core

    • Method Summary

      Modifier and Type Method Description
      void rebalanceSubscriptions()  
      static void refreshStatus​(java.lang.String friendlyName)  
      void setObserver​(io.reactivex.Observer<com.scaleoutsoftware.soss.client.Event> observer)  

      • Methods inherited from class java.lang.Object

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

    • Method Detail

      • rebalanceSubscriptions

        public void rebalanceSubscriptions()
                            throws com.amazonaws.services.iot.client.AWSIotException
        Throws:
        com.amazonaws.services.iot.client.AWSIotException

      • setObserver

        public void setObserver​(io.reactivex.Observer<com.scaleoutsoftware.soss.client.Event> observer)

      • refreshStatus

        public static void refreshStatus​(java.lang.String friendlyName)