Package akka.remote

Interface Summary
AssociationEvent  
AssociationProblem INTERNAL API
ContainerFormats.SelectionEnvelopeOrBuilder  
ContainerFormats.SelectionOrBuilder  
DaemonMsg INTERNAL API
EndpointManager.EndpointPolicy  
EndpointManager.RemotingCommand  
FailureDetector A failure detector must be a thread-safe mutable construct that registers heartbeat events of a resource and is able to decide the availability of that monitored resource.
FailureDetectorRegistry<A> Interface for a registry of Akka failure detectors.
HasSequenceNumber Messages that are to be buffered in AckedSendBuffer or AckedReceiveBuffer has to implement this interface to provide the sequence needed by the buffers.
InboundMessageDispatcher INTERNAL API
PriorityMessage INTERNAL API Messages marked with this trait will be sent before other messages when buffering is active.
RemoteActorRefProvider.TerminatorState  
RemoteMetrics INTERNAL API
RemoteRef  
RemotingLifecycleEvent  
WireFormats.AckAndEnvelopeContainerOrBuilder  
WireFormats.AcknowledgementInfoOrBuilder  
WireFormats.ActorRefDataOrBuilder  
WireFormats.AddressDataOrBuilder  
WireFormats.AkkaControlMessageOrBuilder  
WireFormats.AkkaHandshakeInfoOrBuilder  
WireFormats.AkkaProtocolMessageOrBuilder  
WireFormats.DaemonMsgCreateDataOrBuilder  
WireFormats.DeployDataOrBuilder  
WireFormats.PropsDataOrBuilder  
WireFormats.RemoteEnvelopeOrBuilder  
WireFormats.SerializedMessageOrBuilder  
 

Class Summary
Ack Class representing an acknowledgement with selective negative acknowledgements.
Ack$  
AckedReceiveBuffer<T extends HasSequenceNumber> Implements an immutable receive buffer that buffers incoming messages until they can be safely delivered.
AckedReceiveBuffer$  
AckedSendBuffer<T extends HasSequenceNumber> Implements an immutable resend buffer that buffers messages until they have been acknowledged.
AckedSendBuffer$  
AddressUidExtension  
AddressUidExtension$ Extension that holds a uid that is assigned as a random Int.
AddressUrlEncoder INTERNAL API
AddressUrlEncoder$ INTERNAL API
AssociatedEvent  
AssociatedEvent$  
AssociationErrorEvent  
AssociationErrorEvent$  
ContainerFormats  
ContainerFormats.Selection Protobuf type Selection
ContainerFormats.Selection.Builder Protobuf type Selection
ContainerFormats.SelectionEnvelope Protobuf type SelectionEnvelope
ContainerFormats.SelectionEnvelope.Builder Protobuf type SelectionEnvelope
DaemonMsgCreate INTERNAL API
DaemonMsgCreate$  
DeadlineFailureDetector Implementation of failure detector using an absolute timeout of missing heartbeats to trigger unavailability.
DefaultFailureDetectorRegistry<A> A lock-less thread-safe implementation of FailureDetectorRegistry.
DefaultMessageDispatcher INTERNAL API
DisassociatedEvent  
DisassociatedEvent$  
EndpointActor INTERNAL API
EndpointManager INTERNAL API
EndpointManager.EndpointRegistry  
EndpointManager.Gated  
EndpointManager.Gated$  
EndpointManager.Link  
EndpointManager.Link$  
EndpointManager.Listen  
EndpointManager.Listen$  
EndpointManager.ListensFailure  
EndpointManager.ListensFailure$  
EndpointManager.ListensResult  
EndpointManager.ListensResult$  
EndpointManager.ManagementCommand  
EndpointManager.ManagementCommand$  
EndpointManager.ManagementCommandAck  
EndpointManager.ManagementCommandAck$  
EndpointManager.Pass  
EndpointManager.Pass$  
EndpointManager.Prune$  
EndpointManager.Quarantine  
EndpointManager.Quarantine$  
EndpointManager.Quarantined  
EndpointManager.Quarantined$  
EndpointManager.ResendState  
EndpointManager.ResendState$  
EndpointManager.Send  
EndpointManager.Send$  
EndpointManager.ShutdownAndFlush$  
EndpointManager.StartupFinished$  
EndpointManager$ INTERNAL API
EndpointReader INTERNAL API
EndpointReader$ INTERNAL API
EndpointWriter INTERNAL API
EndpointWriter.AckIdleCheckTimer$  
EndpointWriter.BackoffTimer$  
EndpointWriter.FlushAndStop$  
EndpointWriter.Handle  
EndpointWriter.Handle$  
EndpointWriter.OutboundAck  
EndpointWriter.OutboundAck$  
EndpointWriter.StoppedReading  
EndpointWriter.StoppedReading$  
EndpointWriter.StopReading  
EndpointWriter.StopReading$  
EndpointWriter.TakeOver This message signals that the current association maintained by the local EndpointWriter and EndpointReader is to be overridden by a new inbound association.
EndpointWriter.TakeOver$  
EndpointWriter.TookOver  
EndpointWriter.TookOver$  
EndpointWriter$ INTERNAL API
EventPublisher INTERNAL API
FailureDetector.Clock Abstraction of a clock that returns time in milliseconds.
FailureDetector$  
FailureDetectorLoader INTERNAL API
FailureDetectorLoader$ INTERNAL API
HasSequenceNumber$  
HeartbeatHistory  
HeartbeatHistory$  
HopelessAssociation$  
InvalidAssociation$  
MessageSerializer INTERNAL API
MessageSerializer$ INTERNAL API
PhiAccrualFailureDetector Implementation of 'The Phi Accrual Failure Detector' by Hayashibara et al.
QuarantinedEvent  
QuarantinedEvent$  
RARP INTERNAL API
RARP$ INTERNAL API
ReliableDeliverySupervisor INTERNAL API
ReliableDeliverySupervisor.AttemptSysMsgRedelivery$  
ReliableDeliverySupervisor.GotUid  
ReliableDeliverySupervisor.GotUid$  
ReliableDeliverySupervisor.Idle$  
ReliableDeliverySupervisor.IsIdle$  
ReliableDeliverySupervisor.TooLongIdle$  
ReliableDeliverySupervisor.Ungate$  
ReliableDeliverySupervisor$ INTERNAL API
RemoteActorRef INTERNAL API Remote ActorRef that is used when referencing the Actor on a different node than its "home" node.
RemoteActorRefProvider INTERNAL API Depending on this class is not supported, only the ActorRefProvider interface is supported.
RemoteActorRefProvider.Finished$  
RemoteActorRefProvider.Idle$  
RemoteActorRefProvider.Uninitialized$  
RemoteActorRefProvider.WaitDaemonShutdown$  
RemoteActorRefProvider.WaitTransportShutdown$  
RemoteActorRefProvider$ INTERNAL API
RemoteDeployer INTERNAL API
RemoteDeploymentWatcher INTERNAL API
RemoteDeploymentWatcher.WatchRemote  
RemoteDeploymentWatcher.WatchRemote$  
RemoteDeploymentWatcher$ INTERNAL API
RemoteMetricsExtension INTERNAL API Extension that keeps track of remote metrics, such as max size of different message types.
RemoteMetricsExtension$ INTERNAL API Extension that keeps track of remote metrics, such as max size of different message types.
RemoteMetricsOff INTERNAL API
RemoteMetricsOn INTERNAL API
RemoteScope  
RemoteScope$  
RemoteSettings  
RemoteSystemDaemon INTERNAL API
RemoteTransport INTERNAL API
RemoteWatcher INTERNAL API
RemoteWatcher.ExpectedFirstHeartbeat  
RemoteWatcher.ExpectedFirstHeartbeat$  
RemoteWatcher.Heartbeat$  
RemoteWatcher.HeartbeatRsp  
RemoteWatcher.HeartbeatRsp$  
RemoteWatcher.HeartbeatTick$  
RemoteWatcher.ReapUnreachableTick$  
RemoteWatcher.Rewatch  
RemoteWatcher.RewatchRemote  
RemoteWatcher.RewatchRemote$  
RemoteWatcher.Stats  
RemoteWatcher.Stats$  
RemoteWatcher.UnwatchRemote  
RemoteWatcher.UnwatchRemote$  
RemoteWatcher.WatchRemote  
RemoteWatcher.WatchRemote$  
RemoteWatcher$ INTERNAL API
Remoting INTERNAL API
Remoting.RegisterTransportActor  
Remoting.RegisterTransportActor$  
Remoting.TransportSupervisor  
Remoting$ INTERNAL API
RemotingErrorEvent  
RemotingErrorEvent$  
RemotingListenEvent  
RemotingListenEvent$  
RemotingShutdownEvent  
RemotingShutdownEvent$  
SeqNo  
SeqNo$  
ShutDownAssociation$  
WireFormats  
WireFormats.AckAndEnvelopeContainer Protobuf type AckAndEnvelopeContainer
WireFormats.AckAndEnvelopeContainer.Builder Protobuf type AckAndEnvelopeContainer
WireFormats.AcknowledgementInfo Protobuf type AcknowledgementInfo
WireFormats.AcknowledgementInfo.Builder Protobuf type AcknowledgementInfo
WireFormats.ActorRefData Protobuf type ActorRefData
WireFormats.ActorRefData.Builder Protobuf type ActorRefData
WireFormats.AddressData Protobuf type AddressData
WireFormats.AddressData.Builder Protobuf type AddressData
WireFormats.AkkaControlMessage Protobuf type AkkaControlMessage
WireFormats.AkkaControlMessage.Builder Protobuf type AkkaControlMessage
WireFormats.AkkaHandshakeInfo Protobuf type AkkaHandshakeInfo
WireFormats.AkkaHandshakeInfo.Builder Protobuf type AkkaHandshakeInfo
WireFormats.AkkaProtocolMessage Protobuf type AkkaProtocolMessage
WireFormats.AkkaProtocolMessage.Builder Protobuf type AkkaProtocolMessage
WireFormats.DaemonMsgCreateData Protobuf type DaemonMsgCreateData
WireFormats.DaemonMsgCreateData.Builder Protobuf type DaemonMsgCreateData
WireFormats.DeployData Protobuf type DeployData
WireFormats.DeployData.Builder Protobuf type DeployData
WireFormats.PropsData Protobuf type PropsData
WireFormats.PropsData.Builder Protobuf type PropsData
WireFormats.RemoteEnvelope Protobuf type RemoteEnvelope
WireFormats.RemoteEnvelope.Builder Protobuf type RemoteEnvelope
WireFormats.SerializedMessage Protobuf type SerializedMessage
WireFormats.SerializedMessage.Builder Protobuf type SerializedMessage
 

Enum Summary
ContainerFormats.PatternType Protobuf enum PatternType
WireFormats.CommandType Protobuf enum CommandType
 

Exception Summary
EndpointAssociationException INTERNAL API
EndpointDisassociatedException INTERNAL API
EndpointException INTERNAL API
HopelessAssociation INTERNAL API
InvalidAssociation INTERNAL API
OversizedPayloadException INTERNAL API
RemoteTransportException RemoteTransportException represents a general failure within a RemoteTransport, such as inability to start, wrong configuration etc.
RemoteTransportExceptionNoStackTrace RemoteTransportException without stack trace.
ResendBufferCapacityReachedException  
ResendUnfulfillableException  
ShutDownAssociation INTERNAL API