akka.remote.transport
Class ActorTransportAdapter

java.lang.Object
  extended by akka.remote.transport.AbstractTransportAdapter
      extended by akka.remote.transport.ActorTransportAdapter
All Implemented Interfaces:
SchemeAugmenter, Transport
Direct Known Subclasses:
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