An adapter that wraps a transport and provides interception capabilities
Base trait for remote activities that are logged by TestTransport
Actor-based transport adapter
This exception is thrown when an error occurred during the Akka protocol handshake.
A Service Provider Interface (SPI) layer for abstracting over logical links (associations) created by a 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 Task returned by ReadHandlerSource. Incoming data is not processed until this registration takes place.
Shared state among TestTransport instances. Coordinates the transports and the means of communication between them.
Signals that we're going to totally black out a connection
This exception is used to indicate a simulated failure in an association.
Provider implementation for creatinginstances.
Message sent to the listener registered to an association (via the TaskCompletionSource returned by ReadHandlerSource)
This exception is thrown when an association setup request is invalid and it is impossible to recover (malformed IP address, unknown hostname, etc...).
Transport implementation used for testing. The TestTransport is basically shared memory between actor systems. It can 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 in production systems.
The type of throttle being applied to a connection.
Used to provide throttling controls for remote Transport instances.
INTERNAL API The throttler transport adapter
The underlying transport reported a non-fatal error
Unthrottles a previously throttled connection
Marker type for whenever new actors / endpoints are associated with this ActorSystem via remoting.
Listener interface for any object that can handle IAssociationEvent messages.
Marker interface for events that the registered listener for a AssociationHandle might receive.
An interface that needs to be implemented by a user of an AssociationHandle in order to listen to association events
Interface for producing adapters that can wrap an underlying transport and augment it with additional behavior.