public class AkkaProtocolTransport extends ActorTransportAdapter
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
Modifier and Type | Class and Description |
---|---|
static class |
AkkaProtocolTransport.AssociateUnderlyingRefuseUid |
static class |
AkkaProtocolTransport.AssociateUnderlyingRefuseUid$ |
ActorTransportAdapter.AssociateUnderlying, ActorTransportAdapter.AssociateUnderlying$, ActorTransportAdapter.DisassociateUnderlying, ActorTransportAdapter.DisassociateUnderlying$, ActorTransportAdapter.ListenerRegistered, ActorTransportAdapter.ListenerRegistered$, ActorTransportAdapter.ListenUnderlying, ActorTransportAdapter.ListenUnderlying$, ActorTransportAdapter.TransportOperation
Transport.ActorAssociationEventListener, Transport.ActorAssociationEventListener$, Transport.AssociationEvent, Transport.AssociationEventListener, Transport.InboundAssociation, Transport.InboundAssociation$, Transport.InvalidAssociationException, Transport.InvalidAssociationException$
Constructor and Description |
---|
AkkaProtocolTransport(Transport wrappedTransport,
akka.actor.ActorSystem system,
AkkaProtocolSettings settings,
AkkaPduCodec codec) |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
addedSchemeIdentifier() |
static int |
AkkaOverhead() |
static java.lang.String |
AkkaScheme() |
scala.concurrent.Future<AkkaProtocolHandle> |
associate(akka.actor.Address remoteAddress,
scala.Option<java.lang.Object> refuseUid) |
scala.concurrent.Future<java.lang.Object> |
managementCommand(java.lang.Object cmd)
This method allows upper layers to send management commands to the transport.
|
protected java.lang.String |
managerName() |
protected akka.actor.Props |
managerProps() |
int |
maximumOverhead() |
static java.util.concurrent.atomic.AtomicInteger |
UniqueId() |
AskTimeout, interceptAssociate, interceptListen, manager, shutdown
associate, boundAddress, ec, isResponsibleFor, listen, maximumPayloadBytes, schemeIdentifier, wrappedTransport
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
augmentScheme, augmentScheme, removeScheme, removeScheme
public AkkaProtocolTransport(Transport wrappedTransport, akka.actor.ActorSystem system, AkkaProtocolSettings settings, AkkaPduCodec codec)
public static java.lang.String AkkaScheme()
public static int AkkaOverhead()
public static java.util.concurrent.atomic.AtomicInteger UniqueId()
public java.lang.String addedSchemeIdentifier()
public scala.concurrent.Future<java.lang.Object> managementCommand(java.lang.Object cmd)
Transport
cmd
- Command message to the transportpublic scala.concurrent.Future<AkkaProtocolHandle> associate(akka.actor.Address remoteAddress, scala.Option<java.lang.Object> refuseUid)
public int maximumOverhead()
maximumOverhead
in class AbstractTransportAdapter
protected java.lang.String managerName()
managerName
in class ActorTransportAdapter
protected akka.actor.Props managerProps()
managerProps
in class ActorTransportAdapter