|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES All Classes | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectakka.remote.transport.AbstractTransportAdapter
akka.remote.transport.ActorTransportAdapter
public abstract class ActorTransportAdapter
Nested Class Summary | |
---|---|
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
|
Nested classes/interfaces inherited from interface akka.remote.transport.Transport |
---|
Transport.ActorAssociationEventListener, Transport.ActorAssociationEventListener$, Transport.AssociationEvent, Transport.AssociationEventListener, Transport.InboundAssociation, Transport.InboundAssociation$, Transport.InvalidAssociationException, Transport.InvalidAssociationException$ |
Constructor Summary | |
---|---|
ActorTransportAdapter(Transport wrappedTransport,
ActorSystem system)
|
Method Summary | |
---|---|
static Timeout |
AskTimeout()
|
void |
interceptAssociate(Address remoteAddress,
scala.concurrent.Promise<AssociationHandle> statusPromise)
|
scala.concurrent.Future<Transport.AssociationEventListener> |
interceptListen(Address listenAddress,
scala.concurrent.Future<Transport.AssociationEventListener> listenerPromise)
|
protected ActorRef |
manager()
|
protected abstract java.lang.String |
managerName()
|
protected abstract Props |
managerProps()
|
scala.concurrent.Future<java.lang.Object> |
shutdown()
Shuts down the transport layer and releases all the corresponding resources. |
Methods inherited from class akka.remote.transport.AbstractTransportAdapter |
---|
associate, ec, isResponsibleFor, listen, maximumOverhead, maximumPayloadBytes, schemeIdentifier, wrappedTransport |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface akka.remote.transport.Transport |
---|
managementCommand |
Methods inherited from interface akka.remote.transport.SchemeAugmenter |
---|
addedSchemeIdentifier, augmentScheme, augmentScheme, removeScheme, removeScheme |
Constructor Detail |
---|
public ActorTransportAdapter(Transport wrappedTransport, ActorSystem system)
Method Detail |
---|
public static Timeout AskTimeout()
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
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES All Classes | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |