package transport
- Alphabetic
- Public
- All
Type Members
-
abstract
class
AbstractTransportAdapter
extends Transport with SchemeAugmenter
An adapter that wraps a transport and provides interception
- abstract class AbstractTransportAdapterHandle extends AssociationHandle with SchemeAugmenter
- abstract class ActorTransportAdapter extends AbstractTransportAdapter
- abstract class ActorTransportAdapterManager extends Actor with RequiresMessageQueue[UnboundedMessageQueueSemantics]
-
class
AkkaProtocolException
extends AkkaException with OnlyCauseStackTrace
- Annotations
- @SerialVersionUID()
-
trait
AssociationHandle
extends AnyRef
An SPI layer for abstracting over logical links (associations) created by a akka.remote.transport.Transport.
An SPI layer for abstracting over logical links (associations) created by a akka.remote.transport.Transport. Handles are responsible for providing an API for sending and receiving from the underlying channel.
To register a listener for processing incoming payload data, the listener must be registered by completing the Promise returned by akka.remote.transport.AssociationHandle#readHandlerPromise. Incoming data is not processed until this registration takes place.
-
final
case class
FailureInjectorException
(msg: String) extends AkkaException with NoStackTrace with Product with Serializable
- Annotations
- @SerialVersionUID()
- class FailureInjectorProvider extends TransportAdapterProvider
- final case class HandshakeInfo (origin: Address, uid: Int, cookie: Option[String]) extends Product with Serializable
- trait SchemeAugmenter extends AnyRef
- final case class TestAssociationHandle (localAddress: Address, remoteAddress: Address, transport: TestTransport, inbound: Boolean) extends AssociationHandle with Product with Serializable
-
class
TestTransport
extends Transport
Transport implementation to be used for testing.
Transport implementation to be used for testing.
The TestTransport is basically a shared memory between actor systems. The TestTransport could be programmed to emulate different failure modes of a Transport implementation. TestTransport keeps a log of the activities it was requested to do. This class is not optimized for performance and MUST not be used as an in-memory transport in production systems.
- class ThrottlerProvider extends TransportAdapterProvider
- class ThrottlerTransportAdapter extends ActorTransportAdapter
-
trait
Transport
extends AnyRef
An SPI layer for implementing asynchronous transport mechanisms.
An SPI layer for implementing asynchronous transport mechanisms. The Transport is responsible for initializing the underlying transmission mechanism and setting up logical links between transport entities.
Transport implementations that are loaded dynamically by the remoting must have a constructor that accepts a com.typesafe.config.Config and an akka.actor.ExtendedActorSystem as parameters.
- trait TransportAdapterProvider extends AnyRef
- class TransportAdapters extends Extension
Value Members
- object ActorTransportAdapter
- object AssociationHandle
- object AssociationRegistry
- object TestTransport
- object ThrottlerTransportAdapter
- object Transport
- object TransportAdaptersExtension extends ExtensionId[TransportAdapters] with ExtensionIdProvider