Package org.apache.pekko.remote
package org.apache.pekko.remote
-
ClassDescriptionDeprecated.Classic remoting is deprecated, use Artery.AckedReceiveBuffer<T extends HasSequenceNumber>Deprecated.Classic remoting is deprecated, use Artery.AckedSendBuffer<T extends HasSequenceNumber>Deprecated.Classic remoting is deprecated, use Artery.Extension that holds a uid that is assigned as a random
LongorIntdepending on which version of remoting that is used.INTERNAL APIINTERNAL API* Defines a remote address.* Defines a remote address.RemoteWatcher.ArteryHeartbeat is empty array RemoteWatcher.ArteryHeartbeatRspRemoteWatcher.ArteryHeartbeat is empty array RemoteWatcher.ArteryHeartbeatRspCompressionProtocol.ActorRefCompressionAdvertisement CompressionProtocol.ClassManifestCompressionAdvertisementCompressionProtocol.ActorRefCompressionAdvertisement CompressionProtocol.ClassManifestCompressionAdvertisementCompressionProtocol.ActorRefCompressionAdvertisementAck CompressionProtocol.ClassManifestCompressionAdvertisementAckCompressionProtocol.ActorRefCompressionAdvertisementAck CompressionProtocol.ClassManifestCompressionAdvertisementAckProtobuf typeFlushAckProtobuf typeFlushAckProtobuf typeHandshakeReqProtobuf typeHandshakeReqGeneric message declaration that is used for all types of message that (currently) have a single address field.Generic message declaration that is used for all types of message that (currently) have a single address field.Protobuf typeQuarantinedProtobuf typeQuarantinedSystemMessageDelivery.Ack SystemMessageDelivery.NackSystemMessageDelivery.Ack SystemMessageDelivery.NackSystemMessageDelivery.SystemMessageEnvelopeSystemMessageDelivery.SystemMessageEnvelope* Defines a remote address with uid.* Defines a remote address with uid.Deprecated.Classic remoting is deprecated, use Artery.Deprecated.Classic remoting is deprecated, use Artery.Deprecated.Classic remoting is deprecated, use Artery.INTERNAL APIExtension provides access to bound addresses.INTERNAL APIINTERNAL APIProtobuf typeActorIdentityProtobuf typeActorIdentityProtobuf typeActorInitializationExceptionProtobuf typeActorInitializationExceptionProtobuf typeActorRefProtobuf typeActorRefProtobuf typeIdentifyProtobuf typeIdentifyProtobuf typeOptionProtobuf typeOptionProtobuf enumPatternTypeProtobuf typePayloadProtobuf typePayloadProtobuf typeSelectionProtobuf typeSelectionProtobuf typeSelectionEnvelopeProtobuf typeSelectionEnvelopeProtobuf typeStackTraceElementProtobuf typeStackTraceElementReplyWith pattern message(s)ReplyWith pattern message(s)Protobuf typeThrowableProtobuf typeThrowableProtobuf typeThrowableNotSerializableProtobuf typeThrowableNotSerializableProtobuf typeWatcherHeartbeatResponseProtobuf typeWatcherHeartbeatResponseINTERNAL APIImplementation of failure detector using an absolute timeout of missing heartbeats to trigger unavailability.A lock-less thread-safe implementation ofFailureDetectorRegistry.Deprecated.Classic remoting is deprecated, use Artery.INTERNAL APIINTERNAL APIINTERNAL APIA 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.Abstraction of a clock that returns time in milliseconds.INTERNAL APIINTERNAL APIInterface for a registry of Pekko failure detectors.Deprecated.Classic remoting is deprecated, use Artery.Deprecated.Classic remoting is deprecated, use Artery.Deprecated.Classic remoting is deprecated, use Artery.Failure detector heartbeat messages are marked with this trait.INTERNAL APIINTERNAL APIINTERNAL APIINTERNAL APIImplementation of 'The Phi Accrual Failure Detector' by Hayashibara et al.INTERNAL API Messages marked with this trait will be sent before other messages when buffering is active.Deprecated.Classic remoting is deprecated, use Artery.INTERNAL APIINTERNAL APIINTERNAL APIINTERNAL APIThis is public with the purpose to document the used markers and properties of log events.This is public with the purpose to document the used markers and properties of log events.INTERNAL APIINTERNAL API Extension that keeps track of remote metrics, such as max size of different message types.INTERNAL API Extension that keeps track of remote metrics, such as max size of different message types.RemoteTransportException represents a general failure within a RemoteTransport, such as inability to start, wrong configuration etc.RemoteTransportExceptionwithout stack trace.INTERNAL APIINTERNAL APIDeprecated.Classic remoting is deprecated, use Artery.Deprecated.Classic remoting is deprecated, use Artery.Deprecated.Classic remoting is deprecated, use Artery.Deprecated.Classic remoting is deprecated, use Artery.Deprecated.Classic remoting is deprecated, use Artery.Deprecated.Classic remoting is deprecated, use Artery.Deprecated.Classic remoting is deprecated, use Artery.Deprecated.Classic remoting is deprecated, use Artery.Protobuf typeDeathWatchNotificationDataProtobuf typeDeathWatchNotificationDataProtobuf typeFailedDataProtobuf typeFailedDataProtobuf typeSuperviseDataProtobuf typeSuperviseDataProtobuf typeSystemMessageProtobuf typeSystemMessageProtobuf enumSystemMessage.TypeProtobuf typeWatchDataProtobuf typeWatchDataDeprecated.Classic remoting is deprecated, use Artery.Protobuf typeAckAndEnvelopeContainerProtobuf typeAckAndEnvelopeContainerProtobuf typeAcknowledgementInfoProtobuf typeAcknowledgementInfo* Defines a remote ActorRef that "remembers" and uses its original Actor instance on the original node.* Defines a remote ActorRef that "remembers" and uses its original Actor instance on the original node.* Defines a remote address.* Defines a remote address.* Defines the type of the PekkoControlMessage command type* Defines org.apache.pekko.remote.DaemonMsgCreate* Defines org.apache.pekko.remote.DaemonMsgCreateProtobuf typeDefaultResizerProtobuf typeDefaultResizer* Serialization of org.apache.pekko.actor.Deploy* Serialization of org.apache.pekko.actor.DeployProtobuf typeFiniteDurationProtobuf typeFiniteDurationProtobuf typeFromConfigProtobuf typeFromConfigProtobuf typeGenericRoutingPoolProtobuf typeGenericRoutingPool* Defines some control messages for the remoting* Defines some control messages for the remotingProtobuf typePekkoHandshakeInfoProtobuf typePekkoHandshakeInfo* Message format of Pekko Protocol.* Message format of Pekko Protocol.* Serialization of org.apache.pekko.actor.Props* Serialization of org.apache.pekko.actor.Props* Defines a remote message.* Defines a remote message.Protobuf typeRemoteRouterConfigProtobuf typeRemoteRouterConfigProtobuf typeRemoteScopeProtobuf typeRemoteScopeProtobuf typeScatterGatherPoolProtobuf typeScatterGatherPool* Defines a message.* Defines a message.Protobuf typeTailChoppingPoolProtobuf typeTailChoppingPool* java.util.concurrent.TimeUnit enum