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

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

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()

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