Package org.apache.pekko.remote.transport

Class ThrottlerTransportAdapter

java.lang.Object

org.apache.pekko.remote.transport.AbstractTransportAdapter

org.apache.pekko.remote.transport.ActorTransportAdapter

org.apache.pekko.remote.transport.ThrottlerTransportAdapter

All Implemented Interfaces:

SchemeAugmenter, Transport

public class ThrottlerTransportAdapter
extends ActorTransportAdapter

Deprecated.

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

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ThrottlerTransportAdapter.Blackhole$	Deprecated.
static interface	ThrottlerTransportAdapter.Direction	Deprecated.
static class	ThrottlerTransportAdapter.Direction$	Deprecated.
static class	ThrottlerTransportAdapter.ForceDisassociate	Deprecated. Management Command to force disassociation of an address.
static class	ThrottlerTransportAdapter.ForceDisassociate$	Deprecated.
static class	ThrottlerTransportAdapter.ForceDisassociateAck$	Deprecated.
static class	ThrottlerTransportAdapter.ForceDisassociateExplicitly	Deprecated. Management Command to force disassociation of an address with an explicit error.
static class	ThrottlerTransportAdapter.ForceDisassociateExplicitly$	Deprecated.
static class	ThrottlerTransportAdapter.SetThrottle	Deprecated.
static class	ThrottlerTransportAdapter.SetThrottle$	Deprecated.
static class	ThrottlerTransportAdapter.SetThrottleAck$	Deprecated.
static interface	ThrottlerTransportAdapter.ThrottleMode	Deprecated.
static class	ThrottlerTransportAdapter.TokenBucket	Deprecated.
static class	ThrottlerTransportAdapter.TokenBucket$	Deprecated.
static class	ThrottlerTransportAdapter.Unthrottled$	Deprecated.

Nested classes/interfaces inherited from class org.apache.pekko.remote.transport.ActorTransportAdapter

ActorTransportAdapter.AssociateUnderlying, ActorTransportAdapter.AssociateUnderlying$, ActorTransportAdapter.DisassociateUnderlying, ActorTransportAdapter.DisassociateUnderlying$, ActorTransportAdapter.ListenerRegistered, ActorTransportAdapter.ListenerRegistered$, ActorTransportAdapter.ListenUnderlying, ActorTransportAdapter.ListenUnderlying$, ActorTransportAdapter.TransportOperation

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
ThrottlerTransportAdapter(Transport _wrappedTransport, ExtendedActorSystem _system)	Deprecated.

Method Summary

Modifier and Type	Method	Description
protected java.lang.String	addedSchemeIdentifier()	Deprecated.
static ThrottlerTransportAdapter.ThrottleMode	blackholeThrottleMode()	Deprecated. Java API: get the ThrottleMode.Blackhole instance
static ThrottlerTransportAdapter.Direction	bothDirection()	Deprecated. Java API: get the Direction.Both instance
scala.concurrent.Future<java.lang.Object>	managementCommand(java.lang.Object cmd)	Deprecated. This method allows upper layers to send management commands to the transport.
protected java.lang.String	managerName()	Deprecated.
protected Props	managerProps()	Deprecated.
protected int	maximumOverhead()	Deprecated.
static ThrottlerTransportAdapter.Direction	receiveDirection()	Deprecated. Java API: get the Direction.Receive instance
static java.lang.String	SchemeIdentifier()	Deprecated.
static ThrottlerTransportAdapter.Direction	sendDirection()	Deprecated. Java API: get the Direction.Send instance
static java.util.concurrent.atomic.AtomicInteger	UniqueId()	Deprecated.
static ThrottlerTransportAdapter.ThrottleMode	unthrottledThrottleMode()	Deprecated. Java API: get the ThrottleMode.Unthrottled instance

Methods inherited from class org.apache.pekko.remote.transport.ActorTransportAdapter

AskTimeout, interceptAssociate, interceptListen, manager, manager_$eq, shutdown

Methods inherited from class org.apache.pekko.remote.transport.AbstractTransportAdapter

associate, ec, isResponsibleFor, listen, 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

augmentScheme, augmentScheme, removeScheme, removeScheme

Constructor Detail

ThrottlerTransportAdapter

public ThrottlerTransportAdapter(Transport _wrappedTransport,
                                 ExtendedActorSystem _system)

Deprecated.

Method Detail

SchemeIdentifier

public static java.lang.String SchemeIdentifier()

Deprecated.

UniqueId

public static java.util.concurrent.atomic.AtomicInteger UniqueId()

Deprecated.

sendDirection

public static ThrottlerTransportAdapter.Direction sendDirection()

Deprecated.

Java API: get the Direction.Send instance

receiveDirection

public static ThrottlerTransportAdapter.Direction receiveDirection()

Deprecated.

Java API: get the Direction.Receive instance

bothDirection

public static ThrottlerTransportAdapter.Direction bothDirection()

Deprecated.

Java API: get the Direction.Both instance

blackholeThrottleMode

public static ThrottlerTransportAdapter.ThrottleMode blackholeThrottleMode()

Deprecated.

Java API: get the ThrottleMode.Blackhole instance

unthrottledThrottleMode

public static ThrottlerTransportAdapter.ThrottleMode unthrottledThrottleMode()

Deprecated.

Java API: get the ThrottleMode.Unthrottled instance

addedSchemeIdentifier

protected java.lang.String addedSchemeIdentifier()

Deprecated.

maximumOverhead

protected int maximumOverhead()

Deprecated.

Specified by:

maximumOverhead in class AbstractTransportAdapter

managerName

protected java.lang.String managerName()

Deprecated.

Specified by:

managerName in class ActorTransportAdapter

managerProps

protected Props managerProps()

Deprecated.

Specified by:

managerProps in class ActorTransportAdapter

managementCommand

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

Deprecated.

Description copied from interface: Transport

This method allows upper layers to send management commands to the transport. It is the responsibility of the sender to send appropriate commands to different transport implementations. Unknown commands will be ignored.

Parameters:

cmd - Command message to the transport

Returns:

Future that succeeds when the command was handled or dropped