Package org.apache.pekko.remote

Interface Summary

Interface	Description
ArteryControlFormats.AddressOrBuilder
ArteryControlFormats.ArteryHeartbeatRspOrBuilder
ArteryControlFormats.CompressionTableAdvertisementAckOrBuilder
ArteryControlFormats.CompressionTableAdvertisementOrBuilder
ArteryControlFormats.FlushAckOrBuilder
ArteryControlFormats.HandshakeReqOrBuilder
ArteryControlFormats.MessageWithAddressOrBuilder
ArteryControlFormats.QuarantinedOrBuilder
ArteryControlFormats.SystemMessageDeliveryAckOrBuilder
ArteryControlFormats.SystemMessageEnvelopeOrBuilder
ArteryControlFormats.UniqueAddressOrBuilder
AssociationEvent	Deprecated. Classic remoting is deprecated, use Artery.
AssociationProblem	INTERNAL API
ContainerFormats.ActorIdentityOrBuilder
ContainerFormats.ActorInitializationExceptionOrBuilder
ContainerFormats.ActorRefOrBuilder
ContainerFormats.IdentifyOrBuilder
ContainerFormats.OptionOrBuilder
ContainerFormats.PayloadOrBuilder
ContainerFormats.SelectionEnvelopeOrBuilder
ContainerFormats.SelectionOrBuilder
ContainerFormats.StackTraceElementOrBuilder
ContainerFormats.StatusReplyErrorMessageOrBuilder
ContainerFormats.ThrowableNotSerializableOrBuilder
ContainerFormats.ThrowableOrBuilder
ContainerFormats.WatcherHeartbeatResponseOrBuilder
DaemonMsg	INTERNAL API
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 Pekko failure detectors.
FailureDetectorWithAddress
HasSequenceNumber	Deprecated. Classic remoting is deprecated, use Artery.
HeartbeatMessage	Failure detector heartbeat messages are marked with this trait.
InboundMessageDispatcher	INTERNAL API
PriorityMessage	INTERNAL API Messages marked with this trait will be sent before other messages when buffering is active.
RemoteMetrics	INTERNAL API
RemoteRef
RemotingLifecycleEvent	Deprecated. Classic remoting is deprecated, use Artery.
SystemMessageFormats.DeathWatchNotificationDataOrBuilder
SystemMessageFormats.FailedDataOrBuilder
SystemMessageFormats.SuperviseDataOrBuilder
SystemMessageFormats.SystemMessageOrBuilder
SystemMessageFormats.WatchDataOrBuilder
WireFormats.AckAndEnvelopeContainerOrBuilder
WireFormats.AcknowledgementInfoOrBuilder
WireFormats.ActorRefDataOrBuilder
WireFormats.AddressDataOrBuilder
WireFormats.DaemonMsgCreateDataOrBuilder
WireFormats.DefaultResizerOrBuilder
WireFormats.DeployDataOrBuilder
WireFormats.FiniteDurationOrBuilder
WireFormats.FromConfigOrBuilder
WireFormats.GenericRoutingPoolOrBuilder
WireFormats.PekkoControlMessageOrBuilder
WireFormats.PekkoHandshakeInfoOrBuilder
WireFormats.PekkoProtocolMessageOrBuilder
WireFormats.PropsDataOrBuilder
WireFormats.RemoteEnvelopeOrBuilder
WireFormats.RemoteRouterConfigOrBuilder
WireFormats.RemoteScopeOrBuilder
WireFormats.ScatterGatherPoolOrBuilder
WireFormats.SerializedMessageOrBuilder
WireFormats.TailChoppingPoolOrBuilder

Class Summary

Class	Description
Ack	Deprecated. Classic remoting is deprecated, use Artery.
Ack$
AckedReceiveBuffer<T extends HasSequenceNumber>	Deprecated. Classic remoting is deprecated, use Artery.
AckedReceiveBuffer$
AckedSendBuffer<T extends HasSequenceNumber>	Deprecated. Classic remoting is deprecated, use Artery.
AckedSendBuffer$
AddressUidExtension
AddressUidExtension$	Extension that holds a uid that is assigned as a random Long or Int depending on which version of remoting that is used.
AddressUrlEncoder	INTERNAL API
AddressUrlEncoder$	INTERNAL API
ArteryControlFormats
ArteryControlFormats.Address	* Defines a remote address.
ArteryControlFormats.Address.Builder	* Defines a remote address.
ArteryControlFormats.ArteryHeartbeatRsp	RemoteWatcher.ArteryHeartbeat is empty array RemoteWatcher.ArteryHeartbeatRsp
ArteryControlFormats.ArteryHeartbeatRsp.Builder	RemoteWatcher.ArteryHeartbeat is empty array RemoteWatcher.ArteryHeartbeatRsp
ArteryControlFormats.CompressionTableAdvertisement	CompressionProtocol.ActorRefCompressionAdvertisement CompressionProtocol.ClassManifestCompressionAdvertisement
ArteryControlFormats.CompressionTableAdvertisement.Builder	CompressionProtocol.ActorRefCompressionAdvertisement CompressionProtocol.ClassManifestCompressionAdvertisement
ArteryControlFormats.CompressionTableAdvertisementAck	CompressionProtocol.ActorRefCompressionAdvertisementAck CompressionProtocol.ClassManifestCompressionAdvertisementAck
ArteryControlFormats.CompressionTableAdvertisementAck.Builder	CompressionProtocol.ActorRefCompressionAdvertisementAck CompressionProtocol.ClassManifestCompressionAdvertisementAck
ArteryControlFormats.FlushAck	Protobuf type FlushAck
ArteryControlFormats.FlushAck.Builder	Protobuf type FlushAck
ArteryControlFormats.HandshakeReq	Protobuf type HandshakeReq
ArteryControlFormats.HandshakeReq.Builder	Protobuf type HandshakeReq
ArteryControlFormats.MessageWithAddress	Generic message declaration that is used for all types of message that (currently) have a single address field.
ArteryControlFormats.MessageWithAddress.Builder	Generic message declaration that is used for all types of message that (currently) have a single address field.
ArteryControlFormats.Quarantined	Protobuf type Quarantined
ArteryControlFormats.Quarantined.Builder	Protobuf type Quarantined
ArteryControlFormats.SystemMessageDeliveryAck	SystemMessageDelivery.Ack SystemMessageDelivery.Nack
ArteryControlFormats.SystemMessageDeliveryAck.Builder	SystemMessageDelivery.Ack SystemMessageDelivery.Nack
ArteryControlFormats.SystemMessageEnvelope	SystemMessageDelivery.SystemMessageEnvelope
ArteryControlFormats.SystemMessageEnvelope.Builder	SystemMessageDelivery.SystemMessageEnvelope
ArteryControlFormats.UniqueAddress	* Defines a remote address with uid.
ArteryControlFormats.UniqueAddress.Builder	* Defines a remote address with uid.
AssociatedEvent	Deprecated. Classic remoting is deprecated, use Artery.
AssociatedEvent$
AssociationErrorEvent	Deprecated. Classic remoting is deprecated, use Artery.
AssociationErrorEvent$
BoundAddressesExtension
BoundAddressesExtension$	Extension provides access to bound addresses.
ByteStringUtils	INTERNAL API
ByteStringUtils$	INTERNAL API
ContainerFormats
ContainerFormats.ActorIdentity	Protobuf type ActorIdentity
ContainerFormats.ActorIdentity.Builder	Protobuf type ActorIdentity
ContainerFormats.ActorInitializationException	Protobuf type ActorInitializationException
ContainerFormats.ActorInitializationException.Builder	Protobuf type ActorInitializationException
ContainerFormats.ActorRef	Protobuf type ActorRef
ContainerFormats.ActorRef.Builder	Protobuf type ActorRef
ContainerFormats.Identify	Protobuf type Identify
ContainerFormats.Identify.Builder	Protobuf type Identify
ContainerFormats.Option	Protobuf type Option
ContainerFormats.Option.Builder	Protobuf type Option
ContainerFormats.Payload	Protobuf type Payload
ContainerFormats.Payload.Builder	Protobuf type Payload
ContainerFormats.Selection	Protobuf type Selection
ContainerFormats.Selection.Builder	Protobuf type Selection
ContainerFormats.SelectionEnvelope	Protobuf type SelectionEnvelope
ContainerFormats.SelectionEnvelope.Builder	Protobuf type SelectionEnvelope
ContainerFormats.StackTraceElement	Protobuf type StackTraceElement
ContainerFormats.StackTraceElement.Builder	Protobuf type StackTraceElement
ContainerFormats.StatusReplyErrorMessage	ReplyWith pattern message(s)
ContainerFormats.StatusReplyErrorMessage.Builder	ReplyWith pattern message(s)
ContainerFormats.Throwable	Protobuf type Throwable
ContainerFormats.Throwable.Builder	Protobuf type Throwable
ContainerFormats.ThrowableNotSerializable	Protobuf type ThrowableNotSerializable
ContainerFormats.ThrowableNotSerializable.Builder	Protobuf type ThrowableNotSerializable
ContainerFormats.WatcherHeartbeatResponse	Protobuf type WatcherHeartbeatResponse
ContainerFormats.WatcherHeartbeatResponse.Builder	Protobuf type WatcherHeartbeatResponse
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.
DisassociatedEvent	Deprecated. Classic remoting is deprecated, use Artery.
DisassociatedEvent$
EndpointManager$	INTERNAL API
EndpointReader$	INTERNAL API
EndpointWriter$	INTERNAL API
FailureDetector.Clock	Abstraction of a clock that returns time in milliseconds.
FailureDetector$
FailureDetectorLoader	INTERNAL API
FailureDetectorLoader$	INTERNAL API
GracefulShutdownQuarantinedEvent	Deprecated. Classic remoting is deprecated, use Artery.
GracefulShutdownQuarantinedEvent$
HasSequenceNumber$	Deprecated. Classic remoting is deprecated, use Artery.
HeartbeatHistory$
HopelessAssociation$
InvalidAssociation$
MessageSerializer	INTERNAL API
MessageSerializer$	INTERNAL API
PhiAccrualFailureDetector	Implementation of 'The Phi Accrual Failure Detector' by Hayashibara et al.
QuarantinedEvent	Deprecated. Classic remoting is deprecated, use Artery.
QuarantinedEvent$	Deprecated. Classic remoting is deprecated, use Artery.
RARP$	INTERNAL API
ReliableDeliverySupervisor$	INTERNAL API
RemoteActorRefProvider$	INTERNAL API
RemoteDeploymentWatcher$	INTERNAL API
RemoteLogMarker	This is public with the purpose to document the used markers and properties of log events.
RemoteLogMarker$	This is public with the purpose to document the used markers and properties of log events.
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.
RemoteScope
RemoteScope$
RemoteSettings
RemoteWatcher$	INTERNAL API
Remoting$	INTERNAL API
RemotingErrorEvent	Deprecated. Classic remoting is deprecated, use Artery.
RemotingErrorEvent$
RemotingListenEvent
RemotingListenEvent$
RemotingShutdownEvent	Deprecated. Classic remoting is deprecated, use Artery.
RemotingShutdownEvent$	Deprecated. Classic remoting is deprecated, use Artery.
SeqNo	Deprecated. Classic remoting is deprecated, use Artery.
SeqNo$	Deprecated. Classic remoting is deprecated, use Artery.
ShutDownAssociation$
SystemMessageFormats
SystemMessageFormats.DeathWatchNotificationData	Protobuf type DeathWatchNotificationData
SystemMessageFormats.DeathWatchNotificationData.Builder	Protobuf type DeathWatchNotificationData
SystemMessageFormats.FailedData	Protobuf type FailedData
SystemMessageFormats.FailedData.Builder	Protobuf type FailedData
SystemMessageFormats.SuperviseData	Protobuf type SuperviseData
SystemMessageFormats.SuperviseData.Builder	Protobuf type SuperviseData
SystemMessageFormats.SystemMessage	Protobuf type SystemMessage
SystemMessageFormats.SystemMessage.Builder	Protobuf type SystemMessage
SystemMessageFormats.WatchData	Protobuf type WatchData
SystemMessageFormats.WatchData.Builder	Protobuf type WatchData
ThisActorSystemQuarantinedEvent	Deprecated. Classic remoting is deprecated, use Artery.
ThisActorSystemQuarantinedEvent$
UniqueAddress
UniqueAddress$
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	* Defines a remote ActorRef that "remembers" and uses its original Actor instance on the original node.
WireFormats.ActorRefData.Builder	* Defines a remote ActorRef that "remembers" and uses its original Actor instance on the original node.
WireFormats.AddressData	* Defines a remote address.
WireFormats.AddressData.Builder	* Defines a remote address.
WireFormats.DaemonMsgCreateData	* Defines org.apache.pekko.remote.DaemonMsgCreate
WireFormats.DaemonMsgCreateData.Builder	* Defines org.apache.pekko.remote.DaemonMsgCreate
WireFormats.DefaultResizer	Protobuf type DefaultResizer
WireFormats.DefaultResizer.Builder	Protobuf type DefaultResizer
WireFormats.DeployData	* Serialization of org.apache.pekko.actor.Deploy
WireFormats.DeployData.Builder	* Serialization of org.apache.pekko.actor.Deploy
WireFormats.FiniteDuration	Protobuf type FiniteDuration
WireFormats.FiniteDuration.Builder	Protobuf type FiniteDuration
WireFormats.FromConfig	Protobuf type FromConfig
WireFormats.FromConfig.Builder	Protobuf type FromConfig
WireFormats.GenericRoutingPool	Protobuf type GenericRoutingPool
WireFormats.GenericRoutingPool.Builder	Protobuf type GenericRoutingPool
WireFormats.PekkoControlMessage	* Defines some control messages for the remoting
WireFormats.PekkoControlMessage.Builder	* Defines some control messages for the remoting
WireFormats.PekkoHandshakeInfo	Protobuf type PekkoHandshakeInfo
WireFormats.PekkoHandshakeInfo.Builder	Protobuf type PekkoHandshakeInfo
WireFormats.PekkoProtocolMessage	* Message format of Pekko Protocol.
WireFormats.PekkoProtocolMessage.Builder	* Message format of Pekko Protocol.
WireFormats.PropsData	* Serialization of org.apache.pekko.actor.Props
WireFormats.PropsData.Builder	* Serialization of org.apache.pekko.actor.Props
WireFormats.RemoteEnvelope	* Defines a remote message.
WireFormats.RemoteEnvelope.Builder	* Defines a remote message.
WireFormats.RemoteRouterConfig	Protobuf type RemoteRouterConfig
WireFormats.RemoteRouterConfig.Builder	Protobuf type RemoteRouterConfig
WireFormats.RemoteScope	Protobuf type RemoteScope
WireFormats.RemoteScope.Builder	Protobuf type RemoteScope
WireFormats.ScatterGatherPool	Protobuf type ScatterGatherPool
WireFormats.ScatterGatherPool.Builder	Protobuf type ScatterGatherPool
WireFormats.SerializedMessage	* Defines a message.
WireFormats.SerializedMessage.Builder	* Defines a message.
WireFormats.TailChoppingPool	Protobuf type TailChoppingPool
WireFormats.TailChoppingPool.Builder	Protobuf type TailChoppingPool

Enum Summary

Enum	Description
ContainerFormats.PatternType	Protobuf enum PatternType
SystemMessageFormats.SystemMessage.Type	Protobuf enum SystemMessage.Type
WireFormats.CommandType	* Defines the type of the PekkoControlMessage command type
WireFormats.TimeUnit	* java.util.concurrent.TimeUnit enum

Exception Summary

Exception	Description
MessageSerializer.SerializationException
NotAllowedClassRemoteDeploymentAttemptException	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	Deprecated. Classic remoting is deprecated, use Artery.
ResendUnfulfillableException	Deprecated. Classic remoting is deprecated, use Artery.