|
|||||||||
| PREV NEXT | FRAMES NO FRAMES | ||||||||
repeated bytes args = 4;
repeated string classes = 5;
repeated fixed64 nacks = 2;
repeated .Selection pattern = 3;
repeated bytes args = 4;
repeated string classes = 5;
repeated string classes = 5;
repeated fixed64 nacks = 2;
repeated .Selection pattern = 3;
repeated .Selection pattern = 3;
repeated .Selection pattern = 3;
repeated .Selection pattern = 3;
repeated .Selection pattern = 3;
repeated .Selection pattern = 3;
Int.ByteStrings.AkkaPduCodec trait.FailureDetector implementation.
FailureDetector implementation.
ASSOCIATE = 1;
TestTransport.SwitchableLoggedBehavior for the associate() method.
Transport.ActorRef instances to a HandleEventListener.AssociationHandle might receive.AssociationHandle
to listen to association events.akka.remote.transport.AssociationHandle.readHandlerPromise) when an inbound payload arrives.CHILD_NAME = 1;
CHILD_PATTERN = 2;
optional .AcknowledgementInfo ack = 1;
repeated bytes args = 4;
repeated string classes = 5;
required string clazz = 3;
required .CommandType commandType = 1;
optional bytes config = 2;
optional string cookie = 3;
required fixed64 cumulativeAck = 1;
required .DeployData deploy = 2;
required .DeployData deploy = 2;
optional string dispatcher = 5;
required bytes enclosedMessage = 1;
optional .RemoteEnvelope envelope = 2;
optional .AkkaHandshakeInfo handshakeInfo = 2;
required string hostname = 2;
optional .AkkaControlMessage instruction = 2;
optional string matcher = 2;
required .SerializedMessage message = 2;
required bytes message = 1;
optional bytes messageManifest = 4;
optional bytes messageManifest = 3;
repeated fixed64 nacks = 2;
required .AddressData origin = 1;
required string path = 1;
required string path = 3;
required string path = 1;
repeated .Selection pattern = 3;
optional bytes payload = 1;
required uint32 port = 3;
required .PropsData props = 1;
optional string protocol = 4;
required .ActorRefData recipient = 1;
optional bytes routerConfig = 3;
optional bytes scope = 4;
optional .ActorRefData sender = 4;
optional fixed64 seq = 5;
required int32 serializerId = 2;
required int32 serializerId = 2;
required .ActorRefData supervisor = 4;
required string system = 1;
required .PatternType type = 1;
required fixed64 uid = 2;
optional bool wildcardFanOut = 5;
PatternTypeSelectionSelectionSelectionEnvelopeSelectionEnvelopeAkkaPduCodec.AkkaPdu instance that represents the PDU contained in the raw
ByteString.
FailureDetectorRegistry.ActorRef
from Akka's protobuf representation in the supplied
ActorSystem.
ActorRef
from Akka's protobuf representation in the supplied
ActorSystem.
DISASSOCIATE_QUARANTINED = 5;
Remote system refused the association since the current system is quarantined
DISASSOCIATE_SHUTTING_DOWN = 4;
Remote system is going down and will not accepts new connections
DISASSOCIATE = 2;
TestTransport.SwitchableLoggedBehavior for the disassociate() method on handles.
AkkaPduCodec.AkkaPdu representation of an Akka PDU and returns its encoded
form as a ByteString.
FailureDetector instances reflectively.FailureDetector instances reflectively.optional .AcknowledgementInfo ack = 1;
optional .AcknowledgementInfo ack = 1;
optional .AcknowledgementInfo ack = 1;
optional .AcknowledgementInfo ack = 1;
optional .AcknowledgementInfo ack = 1;
optional .AcknowledgementInfo ack = 1;
optional .AcknowledgementInfo ack = 1;
repeated bytes args = 4;
repeated bytes args = 4;
repeated bytes args = 4;
repeated bytes args = 4;
repeated bytes args = 4;
repeated bytes args = 4;
repeated bytes args = 4;
repeated bytes args = 4;
repeated bytes args = 4;
repeated string classes = 5;
repeated string classes = 5;
repeated string classes = 5;
repeated string classes = 5;
repeated string classes = 5;
repeated string classes = 5;
repeated string classes = 5;
repeated string classes = 5;
repeated string classes = 5;
repeated string classes = 5;
repeated string classes = 5;
repeated string classes = 5;
required string clazz = 3;
required string clazz = 3;
required string clazz = 3;
required string clazz = 3;
required string clazz = 3;
required string clazz = 3;
required .CommandType commandType = 1;
required .CommandType commandType = 1;
required .CommandType commandType = 1;
optional bytes config = 2;
optional bytes config = 2;
optional bytes config = 2;
optional string cookie = 3;
optional string cookie = 3;
optional string cookie = 3;
optional string cookie = 3;
optional string cookie = 3;
optional string cookie = 3;
required fixed64 cumulativeAck = 1;
required fixed64 cumulativeAck = 1;
required fixed64 cumulativeAck = 1;
required .DeployData deploy = 2;
required .DeployData deploy = 2;
required .DeployData deploy = 2;
required .DeployData deploy = 2;
required .DeployData deploy = 2;
required .DeployData deploy = 2;
required .DeployData deploy = 2;
required .DeployData deploy = 2;
required .DeployData deploy = 2;
required .DeployData deploy = 2;
required .DeployData deploy = 2;
required .DeployData deploy = 2;
required .DeployData deploy = 2;
required .DeployData deploy = 2;
optional string dispatcher = 5;
optional string dispatcher = 5;
optional string dispatcher = 5;
optional string dispatcher = 5;
optional string dispatcher = 5;
optional string dispatcher = 5;
required bytes enclosedMessage = 1;
required bytes enclosedMessage = 1;
required bytes enclosedMessage = 1;
optional .RemoteEnvelope envelope = 2;
optional .RemoteEnvelope envelope = 2;
optional .RemoteEnvelope envelope = 2;
optional .RemoteEnvelope envelope = 2;
optional .RemoteEnvelope envelope = 2;
optional .RemoteEnvelope envelope = 2;
optional .RemoteEnvelope envelope = 2;
optional .AkkaHandshakeInfo handshakeInfo = 2;
optional .AkkaHandshakeInfo handshakeInfo = 2;
optional .AkkaHandshakeInfo handshakeInfo = 2;
optional .AkkaHandshakeInfo handshakeInfo = 2;
optional .AkkaHandshakeInfo handshakeInfo = 2;
optional .AkkaHandshakeInfo handshakeInfo = 2;
optional .AkkaHandshakeInfo handshakeInfo = 2;
required string hostname = 2;
required string hostname = 2;
required string hostname = 2;
required string hostname = 2;
required string hostname = 2;
required string hostname = 2;
optional .AkkaControlMessage instruction = 2;
optional .AkkaControlMessage instruction = 2;
optional .AkkaControlMessage instruction = 2;
optional .AkkaControlMessage instruction = 2;
optional .AkkaControlMessage instruction = 2;
optional .AkkaControlMessage instruction = 2;
optional .AkkaControlMessage instruction = 2;
optional string matcher = 2;
optional string matcher = 2;
optional string matcher = 2;
optional string matcher = 2;
optional string matcher = 2;
optional string matcher = 2;
required .SerializedMessage message = 2;
required .SerializedMessage message = 2;
required .SerializedMessage message = 2;
required bytes message = 1;
required bytes message = 1;
required bytes message = 1;
required .SerializedMessage message = 2;
optional bytes messageManifest = 4;
optional bytes messageManifest = 4;
optional bytes messageManifest = 4;
optional bytes messageManifest = 3;
optional bytes messageManifest = 3;
optional bytes messageManifest = 3;
required .SerializedMessage message = 2;
required .SerializedMessage message = 2;
required .SerializedMessage message = 2;
repeated fixed64 nacks = 2;
repeated fixed64 nacks = 2;
repeated fixed64 nacks = 2;
repeated fixed64 nacks = 2;
repeated fixed64 nacks = 2;
repeated fixed64 nacks = 2;
repeated fixed64 nacks = 2;
repeated fixed64 nacks = 2;
repeated fixed64 nacks = 2;
required .AddressData origin = 1;
required .AddressData origin = 1;
required .AddressData origin = 1;
required .AddressData origin = 1;
required .AddressData origin = 1;
required .AddressData origin = 1;
required .AddressData origin = 1;
required string path = 1;
required string path = 1;
required string path = 1;
required string path = 3;
required string path = 3;
required string path = 3;
required string path = 1;
required string path = 1;
required string path = 1;
required string path = 1;
required string path = 1;
required string path = 1;
required string path = 3;
required string path = 3;
required string path = 3;
required string path = 1;
required string path = 1;
required string path = 1;
repeated .Selection pattern = 3;
repeated .Selection pattern = 3;
repeated .Selection pattern = 3;
repeated .Selection pattern = 3;
repeated .Selection pattern = 3;
repeated .Selection pattern = 3;
repeated .Selection pattern = 3;
repeated .Selection pattern = 3;
repeated .Selection pattern = 3;
repeated .Selection pattern = 3;
repeated .Selection pattern = 3;
repeated .Selection pattern = 3;
repeated .Selection pattern = 3;
repeated .Selection pattern = 3;
repeated .Selection pattern = 3;
repeated .Selection pattern = 3;
repeated .Selection pattern = 3;
optional bytes payload = 1;
optional bytes payload = 1;
optional bytes payload = 1;
required uint32 port = 3;
required uint32 port = 3;
required uint32 port = 3;
required .PropsData props = 1;
required .PropsData props = 1;
required .PropsData props = 1;
required .PropsData props = 1;
required .PropsData props = 1;
required .PropsData props = 1;
required .PropsData props = 1;
optional string protocol = 4;
optional string protocol = 4;
optional string protocol = 4;
optional string protocol = 4;
optional string protocol = 4;
optional string protocol = 4;
required .ActorRefData recipient = 1;
required .ActorRefData recipient = 1;
required .ActorRefData recipient = 1;
required .ActorRefData recipient = 1;
required .ActorRefData recipient = 1;
required .ActorRefData recipient = 1;
required .ActorRefData recipient = 1;
optional bytes routerConfig = 3;
optional bytes routerConfig = 3;
optional bytes routerConfig = 3;
optional bytes scope = 4;
optional bytes scope = 4;
optional bytes scope = 4;
optional .ActorRefData sender = 4;
optional .ActorRefData sender = 4;
optional .ActorRefData sender = 4;
optional .ActorRefData sender = 4;
optional .ActorRefData sender = 4;
optional .ActorRefData sender = 4;
optional .ActorRefData sender = 4;
optional fixed64 seq = 5;
optional fixed64 seq = 5;
optional fixed64 seq = 5;
required int32 serializerId = 2;
required int32 serializerId = 2;
required int32 serializerId = 2;
required int32 serializerId = 2;
required int32 serializerId = 2;
required int32 serializerId = 2;
required .ActorRefData supervisor = 4;
required .ActorRefData supervisor = 4;
required .ActorRefData supervisor = 4;
required .ActorRefData supervisor = 4;
required .ActorRefData supervisor = 4;
required .ActorRefData supervisor = 4;
required .ActorRefData supervisor = 4;
required string system = 1;
required string system = 1;
required string system = 1;
required string system = 1;
required string system = 1;
required string system = 1;
required .PatternType type = 1;
required .PatternType type = 1;
required .PatternType type = 1;
required fixed64 uid = 2;
required fixed64 uid = 2;
required fixed64 uid = 2;
optional bool wildcardFanOut = 5;
optional bool wildcardFanOut = 5;
optional bool wildcardFanOut = 5;
optional .AcknowledgementInfo ack = 1;
optional .AcknowledgementInfo ack = 1;
optional .AcknowledgementInfo ack = 1;
required string clazz = 3;
required string clazz = 3;
required string clazz = 3;
required .CommandType commandType = 1;
required .CommandType commandType = 1;
required .CommandType commandType = 1;
optional bytes config = 2;
optional bytes config = 2;
optional bytes config = 2;
optional string cookie = 3;
optional string cookie = 3;
optional string cookie = 3;
required fixed64 cumulativeAck = 1;
required fixed64 cumulativeAck = 1;
required fixed64 cumulativeAck = 1;
required .DeployData deploy = 2;
required .DeployData deploy = 2;
required .DeployData deploy = 2;
required .DeployData deploy = 2;
required .DeployData deploy = 2;
required .DeployData deploy = 2;
optional string dispatcher = 5;
optional string dispatcher = 5;
optional string dispatcher = 5;
required bytes enclosedMessage = 1;
required bytes enclosedMessage = 1;
required bytes enclosedMessage = 1;
optional .RemoteEnvelope envelope = 2;
optional .RemoteEnvelope envelope = 2;
optional .RemoteEnvelope envelope = 2;
optional .AkkaHandshakeInfo handshakeInfo = 2;
optional .AkkaHandshakeInfo handshakeInfo = 2;
optional .AkkaHandshakeInfo handshakeInfo = 2;
required string hostname = 2;
required string hostname = 2;
required string hostname = 2;
optional .AkkaControlMessage instruction = 2;
optional .AkkaControlMessage instruction = 2;
optional .AkkaControlMessage instruction = 2;
optional string matcher = 2;
optional string matcher = 2;
optional string matcher = 2;
required .SerializedMessage message = 2;
required .SerializedMessage message = 2;
required .SerializedMessage message = 2;
required bytes message = 1;
required bytes message = 1;
required bytes message = 1;
optional bytes messageManifest = 4;
optional bytes messageManifest = 4;
optional bytes messageManifest = 4;
optional bytes messageManifest = 3;
optional bytes messageManifest = 3;
optional bytes messageManifest = 3;
required .AddressData origin = 1;
required .AddressData origin = 1;
required .AddressData origin = 1;
required string path = 1;
required string path = 1;
required string path = 1;
required string path = 3;
required string path = 3;
required string path = 3;
required string path = 1;
required string path = 1;
required string path = 1;
optional bytes payload = 1;
optional bytes payload = 1;
optional bytes payload = 1;
required uint32 port = 3;
required uint32 port = 3;
required uint32 port = 3;
required .PropsData props = 1;
required .PropsData props = 1;
required .PropsData props = 1;
optional string protocol = 4;
optional string protocol = 4;
optional string protocol = 4;
required .ActorRefData recipient = 1;
required .ActorRefData recipient = 1;
required .ActorRefData recipient = 1;
optional bytes routerConfig = 3;
optional bytes routerConfig = 3;
optional bytes routerConfig = 3;
optional bytes scope = 4;
optional bytes scope = 4;
optional bytes scope = 4;
optional .ActorRefData sender = 4;
optional .ActorRefData sender = 4;
optional .ActorRefData sender = 4;
optional fixed64 seq = 5;
optional fixed64 seq = 5;
optional fixed64 seq = 5;
AckedSendBuffer or AckedReceiveBuffer has
to implement this interface to provide the sequence needed by the buffers.required int32 serializerId = 2;
required int32 serializerId = 2;
required int32 serializerId = 2;
required int32 serializerId = 2;
required int32 serializerId = 2;
required int32 serializerId = 2;
required .ActorRefData supervisor = 4;
required .ActorRefData supervisor = 4;
required .ActorRefData supervisor = 4;
required string system = 1;
required string system = 1;
required string system = 1;
required .PatternType type = 1;
required .PatternType type = 1;
required .PatternType type = 1;
required fixed64 uid = 2;
required fixed64 uid = 2;
required fixed64 uid = 2;
optional bool wildcardFanOut = 5;
optional bool wildcardFanOut = 5;
optional bool wildcardFanOut = 5;
HEARTBEAT = 3;
TestTransport.AssociationRegistry to identify associations.
TestTransport.SwitchableLoggedBehavior for the listen() method.
FailureDetector implementation.
FailureDetector implementation.
optional .AcknowledgementInfo ack = 1;
required .DeployData deploy = 2;
required .DeployData deploy = 2;
optional .RemoteEnvelope envelope = 2;
optional .AkkaHandshakeInfo handshakeInfo = 2;
optional .AkkaControlMessage instruction = 2;
required .SerializedMessage message = 2;
required .AddressData origin = 1;
required .PropsData props = 1;
required .ActorRefData recipient = 1;
optional .ActorRefData sender = 4;
required .ActorRefData supervisor = 4;
PARENT = 0;
RemoteWatcher Props.
RemoteWatcher Props.
com.google.protobuf.MessagesAssociationHandle.HandleEventListener
to register a listener responsible for handling incoming payload.
ActorRefProvider interface is supported.AddressTerminated.RouterConfig implementation for remote deployment on defined
target nodes.RemoteTransportException without stack trace.repeated .Selection pattern = 3;
ActorRef to Akka's
protobuf representation.
ActorRef to Akka's
protobuf representation.
optional .AcknowledgementInfo ack = 1;
optional .AcknowledgementInfo ack = 1;
repeated bytes args = 4;
repeated string classes = 5;
required string clazz = 3;
required string clazz = 3;
required .CommandType commandType = 1;
optional bytes config = 2;
optional string cookie = 3;
optional string cookie = 3;
required fixed64 cumulativeAck = 1;
required .DeployData deploy = 2;
required .DeployData deploy = 2;
required .DeployData deploy = 2;
required .DeployData deploy = 2;
optional string dispatcher = 5;
optional string dispatcher = 5;
required bytes enclosedMessage = 1;
optional .RemoteEnvelope envelope = 2;
optional .RemoteEnvelope envelope = 2;
optional .AkkaHandshakeInfo handshakeInfo = 2;
optional .AkkaHandshakeInfo handshakeInfo = 2;
required string hostname = 2;
required string hostname = 2;
optional .AkkaControlMessage instruction = 2;
optional .AkkaControlMessage instruction = 2;
optional string matcher = 2;
optional string matcher = 2;
required .SerializedMessage message = 2;
required .SerializedMessage message = 2;
required bytes message = 1;
optional bytes messageManifest = 4;
optional bytes messageManifest = 3;
repeated fixed64 nacks = 2;
required .AddressData origin = 1;
required .AddressData origin = 1;
required string path = 1;
required string path = 3;
required string path = 1;
required string path = 1;
required string path = 3;
required string path = 1;
repeated .Selection pattern = 3;
repeated .Selection pattern = 3;
optional bytes payload = 1;
required uint32 port = 3;
required .PropsData props = 1;
required .PropsData props = 1;
optional string protocol = 4;
optional string protocol = 4;
required .ActorRefData recipient = 1;
required .ActorRefData recipient = 1;
optional bytes routerConfig = 3;
optional bytes scope = 4;
optional .ActorRefData sender = 4;
optional .ActorRefData sender = 4;
optional fixed64 seq = 5;
required int32 serializerId = 2;
required int32 serializerId = 2;
required .ActorRefData supervisor = 4;
required .ActorRefData supervisor = 4;
required string system = 1;
required string system = 1;
required .PatternType type = 1;
required fixed64 uid = 2;
optional bool wildcardFanOut = 5;
TestTransport.SwitchableLoggedBehavior for the shutdown() method.
TestTransport.TestTransport instances.ActorRef instances to an AssociationEventListener.Transport.AssociationEventListener registered to a transport
(via the Promise returned by akka.remote.transport.Transport.listen) when an inbound association request arrives.AckAndEnvelopeContainerAckAndEnvelopeContainerAcknowledgementInfoAcknowledgementInfoActorRefData
Defines a remote ActorRef that "remembers" and uses its original Actor instance
on the original node.ActorRefData
Defines a remote ActorRef that "remembers" and uses its original Actor instance
on the original node.AddressData
Defines a remote address.AddressData
Defines a remote address.AkkaControlMessage
Defines some control messages for the remoting
AkkaControlMessage
Defines some control messages for the remoting
AkkaHandshakeInfoAkkaHandshakeInfoAkkaProtocolMessage
Message format of Akka Protocol.AkkaProtocolMessage
Message format of Akka Protocol.CommandType
Defines the type of the AkkaControlMessage command type
DaemonMsgCreateData
Defines akka.remote.DaemonMsgCreate
DaemonMsgCreateData
Defines akka.remote.DaemonMsgCreate
DeployData
Serialization of akka.actor.Deploy
DeployData
Serialization of akka.actor.Deploy
PropsData
Serialization of akka.actor.Props
PropsData
Serialization of akka.actor.Props
RemoteEnvelope
Defines a remote message.RemoteEnvelope
Defines a remote message.SerializedMessage
Defines a message.SerializedMessage
Defines a message.TestTransport.SwitchableLoggedBehavior for the write() method on handles.
|
|||||||||
| PREV NEXT | FRAMES NO FRAMES | ||||||||