public abstract class ActorTransportAdapter extends AbstractTransportAdapter
Modifier and Type | Class and Description |
---|---|
static class |
ActorTransportAdapter.AssociateUnderlying |
static class |
ActorTransportAdapter.AssociateUnderlying$ |
static class |
ActorTransportAdapter.DisassociateUnderlying |
static class |
ActorTransportAdapter.DisassociateUnderlying$ |
static class |
ActorTransportAdapter.ListenerRegistered |
static class |
ActorTransportAdapter.ListenerRegistered$ |
static class |
ActorTransportAdapter.ListenUnderlying |
static class |
ActorTransportAdapter.ListenUnderlying$ |
static interface |
ActorTransportAdapter.TransportOperation |
Transport.ActorAssociationEventListener, Transport.ActorAssociationEventListener$, Transport.AssociationEvent, Transport.AssociationEventListener, Transport.InboundAssociation, Transport.InboundAssociation$, Transport.InvalidAssociationException, Transport.InvalidAssociationException$
Constructor and Description |
---|
ActorTransportAdapter(Transport wrappedTransport,
ActorSystem system) |
Modifier and Type | Method and Description |
---|---|
protected abstract static java.lang.String |
addedSchemeIdentifier() |
static Timeout |
AskTimeout() |
static scala.concurrent.Future<AssociationHandle> |
associate(Address remoteAddress) |
protected static Address |
augmentScheme(Address address) |
protected static java.lang.String |
augmentScheme(java.lang.String originalScheme) |
static Address |
boundAddress() |
static scala.concurrent.ExecutionContext |
ec() |
void |
interceptAssociate(Address remoteAddress,
scala.concurrent.Promise<AssociationHandle> statusPromise) |
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() |
static scala.concurrent.Future<java.lang.Object> |
managementCommand(java.lang.Object cmd) |
protected ActorRef |
manager() |
protected abstract java.lang.String |
managerName() |
protected abstract Props |
managerProps() |
protected abstract static 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() |
scala.concurrent.Future<java.lang.Object> |
shutdown()
Shuts down the transport layer and releases all the corresponding resources.
|
protected static Transport |
wrappedTransport() |
associate, boundAddress, ec, isResponsibleFor, listen, maximumOverhead, maximumPayloadBytes, schemeIdentifier, wrappedTransport
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
managementCommand
addedSchemeIdentifier, augmentScheme, augmentScheme, removeScheme, removeScheme
public ActorTransportAdapter(Transport wrappedTransport, ActorSystem system)
public static Timeout AskTimeout()
public static scala.concurrent.Future<java.lang.Object> managementCommand(java.lang.Object cmd)
protected abstract static java.lang.String addedSchemeIdentifier()
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()
protected abstract static int maximumOverhead()
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()
public static scala.concurrent.Future<AssociationHandle> associate(Address remoteAddress)
protected abstract java.lang.String managerName()
protected abstract Props managerProps()
protected ActorRef manager()
public scala.concurrent.Future<Transport.AssociationEventListener> interceptListen(Address listenAddress, scala.concurrent.Future<Transport.AssociationEventListener> listenerPromise)
interceptListen
in class AbstractTransportAdapter
public void interceptAssociate(Address remoteAddress, scala.concurrent.Promise<AssociationHandle> statusPromise)
interceptAssociate
in class AbstractTransportAdapter
public scala.concurrent.Future<java.lang.Object> shutdown()
Transport
The transport SHOULD try flushing pending writes before becoming completely closed.
shutdown
in interface Transport
shutdown
in class AbstractTransportAdapter