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,
akka.actor.ActorSystem system) |
Modifier and Type | Method and Description |
---|---|
static akka.util.Timeout |
AskTimeout() |
void |
interceptAssociate(akka.actor.Address remoteAddress,
scala.concurrent.Promise<AssociationHandle> statusPromise) |
scala.concurrent.Future<Transport.AssociationEventListener> |
interceptListen(akka.actor.Address listenAddress,
scala.concurrent.Future<Transport.AssociationEventListener> listenerPromise) |
protected akka.actor.ActorRef |
manager() |
protected abstract java.lang.String |
managerName() |
protected abstract akka.actor.Props |
managerProps() |
scala.concurrent.Future<java.lang.Object> |
shutdown()
Shuts down the transport layer and releases all the corresponding resources.
|
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, akka.actor.ActorSystem system)
public static akka.util.Timeout AskTimeout()
protected abstract java.lang.String managerName()
protected abstract akka.actor.Props managerProps()
protected akka.actor.ActorRef manager()
public scala.concurrent.Future<Transport.AssociationEventListener> interceptListen(akka.actor.Address listenAddress, scala.concurrent.Future<Transport.AssociationEventListener> listenerPromise)
interceptListen
in class AbstractTransportAdapter
public void interceptAssociate(akka.actor.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