Package akka.remote.transport

Class ActorTransportAdapter

java.lang.Object

akka.remote.transport.AbstractTransportAdapter

akka.remote.transport.ActorTransportAdapter

All Implemented Interfaces:

SchemeAugmenter, Transport

Direct Known Subclasses:

AkkaProtocolTransport, ThrottlerTransportAdapter

public abstract class ActorTransportAdapter
extends AbstractTransportAdapter

Nested Class Summary

Nested Classes

Modifier and Type	Class	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

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

Constructors

Constructor	Description
ActorTransportAdapter(Transport wrappedTransport, ActorSystem system)

Method Summary

Modifier and Type	Method	Description
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 void	manager_$eq(ActorRef x$1)
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, boundAddress, 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.SchemeAugmenter

addedSchemeIdentifier, augmentScheme, augmentScheme, removeScheme, removeScheme

Methods inherited from interface akka.remote.transport.Transport

managementCommand

Constructor Detail

ActorTransportAdapter

public ActorTransportAdapter(Transport wrappedTransport,
                             ActorSystem system)

Method Detail

AskTimeout

public static Timeout AskTimeout()

managerName

protected abstract java.lang.String managerName()

managerProps

protected abstract Props managerProps()

manager

protected ActorRef manager()

manager_$eq

protected void manager_$eq(ActorRef x$1)

interceptListen

public scala.concurrent.Future<Transport.AssociationEventListener> interceptListen(Address listenAddress,
                                                                                   scala.concurrent.Future<Transport.AssociationEventListener> listenerPromise)

Specified by:

interceptListen in class AbstractTransportAdapter

interceptAssociate

public void interceptAssociate(Address remoteAddress,
                               scala.concurrent.Promise<AssociationHandle> statusPromise)

Specified by:

interceptAssociate in class AbstractTransportAdapter

shutdown

public scala.concurrent.Future<java.lang.Object> shutdown()

Description copied from interface: Transport

Shuts down the transport layer and releases all the corresponding resources. Shutdown is asynchronous signalling the end of the shutdown by completing the returned future.

The transport SHOULD try flushing pending writes before becoming completely closed.

Specified by:

shutdown in interface Transport

Overrides:

shutdown in class AbstractTransportAdapter

Returns:

Future signalling the completion of shutdown