Class ThrottlerTransportAdapter

    • Method Detail

      • SchemeIdentifier

        public static java.lang.String SchemeIdentifier()
      • UniqueId

        public static java.util.concurrent.atomic.AtomicInteger UniqueId()
      • addedSchemeIdentifier

        protected java.lang.String addedSchemeIdentifier()
      • managementCommand

        public scala.concurrent.Future<java.lang.Object> managementCommand​(java.lang.Object cmd)
        Description copied from interface: Transport
        This method allows upper layers to send management commands to the transport. It is the responsibility of the sender to send appropriate commands to different transport implementations. Unknown commands will be ignored.

        cmd - Command message to the transport
        Future that succeeds when the command was handled or dropped