Package org.apache.pekko.remote.transport

Class ActorTransportAdapter

java.lang.Object

org.apache.pekko.remote.transport.AbstractTransportAdapter

org.apache.pekko.remote.transport.ActorTransportAdapter

All Implemented Interfaces:

SchemeAugmenter, Transport

Direct Known Subclasses:

ThrottlerTransportAdapter

public abstract class ActorTransportAdapter
extends AbstractTransportAdapter

Deprecated.

Classic remoting is deprecated, use Artery. Since Akka 2.6.0.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	ActorTransportAdapter.AssociateUnderlying	Deprecated.
static class	ActorTransportAdapter.AssociateUnderlying$	Deprecated.
static final class	ActorTransportAdapter.DisassociateUnderlying	Deprecated.
static class	ActorTransportAdapter.DisassociateUnderlying$	Deprecated.
static final class	ActorTransportAdapter.ListenerRegistered	Deprecated.
static class	ActorTransportAdapter.ListenerRegistered$	Deprecated.
static final class	ActorTransportAdapter.ListenUnderlying	Deprecated.
static class	ActorTransportAdapter.ListenUnderlying$	Deprecated.
static interface	ActorTransportAdapter.TransportOperation	Deprecated.

Nested classes/interfaces inherited from interface org.apache.pekko.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)	Deprecated.

Method Summary

Modifier and Type	Method	Description
static Timeout	AskTimeout()	Deprecated.
void	interceptAssociate(Address remoteAddress, scala.concurrent.Promise<AssociationHandle> statusPromise)	Deprecated.
scala.concurrent.Future<Transport.AssociationEventListener>	interceptListen(Address listenAddress, scala.concurrent.Future<Transport.AssociationEventListener> listenerPromise)	Deprecated.
protected ActorRef	manager()	Deprecated.
protected void	manager_$eq(ActorRef x$1)	Deprecated.
protected abstract String	managerName()	Deprecated.
protected abstract Props	managerProps()	Deprecated.
scala.concurrent.Future<Object>	shutdown()	Deprecated. Shuts down the transport layer and releases all the corresponding resources.

Methods inherited from class org.apache.pekko.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 org.apache.pekko.remote.transport.SchemeAugmenter

addedSchemeIdentifier, augmentScheme, augmentScheme, removeScheme, removeScheme

Methods inherited from interface org.apache.pekko.remote.transport.Transport

managementCommand

Constructor Details

ActorTransportAdapter

public ActorTransportAdapter(Transport wrappedTransport,
 ActorSystem system)

Deprecated.

Method Details

AskTimeout

public static Timeout AskTimeout()

Deprecated.

managerName

protected abstract String managerName()

Deprecated.

managerProps

protected abstract Props managerProps()

Deprecated.

manager

protected ActorRef manager()

Deprecated.

manager_$eq

protected void manager_$eq(ActorRef x$1)

Deprecated.

interceptListen

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

Deprecated.

Specified by:

interceptListen in class AbstractTransportAdapter

interceptAssociate

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

Deprecated.

Specified by:

interceptAssociate in class AbstractTransportAdapter

shutdown

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

Deprecated.

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