Class AkkaProtocolTransport

  • All Implemented Interfaces:
    SchemeAugmenter, Transport

    public class AkkaProtocolTransport
    extends ActorTransportAdapter
    Implementation of the Akka protocol as a Transport that wraps an underlying Transport instance.

    Features provided by this transport are: - Soft-state associations via the use of heartbeats and failure detectors - Secure-cookie handling - Transparent origin address handling - pluggable codecs to encode and decode Akka PDUs

    It is not possible to load this transport dynamically using the configuration of remoting, because it does not expose a constructor with Config and ExtendedActorSystem parameters. This transport is instead loaded automatically by Remoting to wrap all the dynamically loaded transports.

    param: wrappedTransport the underlying transport that will be used for communication param: system the actor system param: settings the configuration options of the Akka protocol param: codec the codec that will be used to encode/decode Akka PDUs

    • Method Detail

      • AkkaScheme

        public static java.lang.String AkkaScheme()
      • AkkaOverhead

        public static int AkkaOverhead()
      • UniqueId

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

        public 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
      • associate

        public scala.concurrent.Future<AkkaProtocolHandle> associate​(Address remoteAddress,
                                                                     scala.Option<java.lang.Object> refuseUid)