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,
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(Address remoteAddress,
scala.Option<java.lang.Object> refuseUid) |
protected static Address |
augmentScheme(Address address) |
protected static java.lang.String |
augmentScheme(java.lang.String originalScheme) |
static Address |
boundAddress() |
static scala.concurrent.ExecutionContext |
ec() |
static void |
interceptAssociate(Address remoteAddress,
scala.concurrent.Promise<AssociationHandle> statusPromise) |
static scala.concurrent.Future<Transport.AssociationEventListener> |
interceptListen(Address listenAddress,
scala.concurrent.Future<Transport.AssociationEventListener> listenerPromise) |
static boolean |
isResponsibleFor(Address address) |
static scala.concurrent.Future<scala.Tuple2<Address,scala.concurrent.Promise<Transport.AssociationEventListener>>> |
listen() |
scala.concurrent.Future<java.lang.Object> |
managementCommand(java.lang.Object cmd)
This method allows upper layers to send management commands to the transport.
|
protected static void |
manager_$eq(ActorRef x$1) |
protected static ActorRef |
manager() |
protected java.lang.String |
managerName() |
protected Props |
managerProps() |
int |
maximumOverhead() |
static int |
maximumPayloadBytes() |
protected static Address |
removeScheme(Address address) |
protected static java.lang.String |
removeScheme(java.lang.String scheme) |
static java.lang.String |
schemeIdentifier() |
static scala.concurrent.Future<java.lang.Object> |
shutdown() |
static java.util.concurrent.atomic.AtomicInteger |
UniqueId() |
protected static Transport |
wrappedTransport() |
AskTimeout, associate, 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, ActorSystem system, AkkaProtocolSettings settings, AkkaPduCodec codec)
public static java.lang.String AkkaScheme()
public static int AkkaOverhead()
public static java.util.concurrent.atomic.AtomicInteger UniqueId()
protected static java.lang.String augmentScheme(java.lang.String originalScheme)
protected static java.lang.String removeScheme(java.lang.String scheme)
protected static Transport wrappedTransport()
public static scala.concurrent.ExecutionContext ec()
public static java.lang.String schemeIdentifier()
public static boolean isResponsibleFor(Address address)
public static int maximumPayloadBytes()
public static scala.concurrent.Future<scala.Tuple2<Address,scala.concurrent.Promise<Transport.AssociationEventListener>>> listen()
public static Address boundAddress()
protected static ActorRef manager()
protected static void manager_$eq(ActorRef x$1)
public static scala.concurrent.Future<Transport.AssociationEventListener> interceptListen(Address listenAddress, scala.concurrent.Future<Transport.AssociationEventListener> listenerPromise)
public static void interceptAssociate(Address remoteAddress, scala.concurrent.Promise<AssociationHandle> statusPromise)
public static scala.concurrent.Future<java.lang.Object> shutdown()
public java.lang.String addedSchemeIdentifier()
addedSchemeIdentifier
in interface SchemeAugmenter
addedSchemeIdentifier
in class ActorTransportAdapter
public scala.concurrent.Future<java.lang.Object> managementCommand(java.lang.Object cmd)
Transport
managementCommand
in interface Transport
managementCommand
in class ActorTransportAdapter
cmd
- Command message to the transportpublic scala.concurrent.Future<AkkaProtocolHandle> associate(Address remoteAddress, scala.Option<java.lang.Object> refuseUid)
public int maximumOverhead()
maximumOverhead
in class ActorTransportAdapter
protected java.lang.String managerName()
managerName
in class ActorTransportAdapter
protected Props managerProps()
managerProps
in class ActorTransportAdapter