|
|||||||||
| PREV NEXT | FRAMES NO FRAMES | ||||||||
Abort = 3;
ReceiveBuilder):
command handler.ReceiveBuilder)ReceiveBuilder)ActivationMessageActor.
Actor.
Actor.
Actor.
Props to determine the type of actor which will
be created.
org.apache.camel.Endpoints that send messages to Consumer actors through an ActorProducer.ActorEndpoint.ActorRef
param: actorPath the String representation of the path to the actorActorEndpointPathActorClassification
An EventBus where the Subscribers are ActorRefs and the Classifier is ActorRef
Means that ActorRefs "listen" to other ActorRefs
E is the Event typeActorSystem.
".." signifies the parent of an actor.
".." signifies the parent of an actor.
Identify.Kill messageActorSelection.resolveOne(akka.util.Timeout) can't identify the actor the
Future is completed with this failure.akka.camel.internal.component.ActorEndPointActorSystem.Routee that sends the messages to an ActorRef.org.apache.camel.model.ProcessorDefinition.ActorSelection from the given path, which is
parsed for wildcards (these are replaced by regular expressions
internally).
ActorSelection from the given path, which is
parsed for wildcards (these are replaced by regular expressions
internally).
Routee that sends the messages to an ActorSelection.ActorSystem
Returns a default value of bundle--ActorSystem is no name is being specified
repeated .UniqueAddress allAddresses = 1;
repeated .UniqueAddress allAddresses = 1;
repeated .UniqueAddress allAddresses = 1;
repeated .UniqueAddress allAddresses = 1;
repeated .Address allAddresses = 1;
repeated .Address allAddresses = 1;
repeated .Address allAddresses = 1;
repeated .Address allAddresses = 1;
repeated .UniqueAddress allAddresses = 1;
repeated .UniqueAddress allAddresses = 1;
repeated .Address allAddresses = 1;
repeated .Address allAddresses = 1;
repeated .UniqueAddress allAddresses = 1;
repeated .Address allAddresses = 1;
repeated string allHashes = 3;
repeated string allHashes = 2;
repeated string allMetricNames = 2;
repeated string allRoles = 2;
repeated bytes args = 4;
repeated .PersistentMessage batch = 1;
repeated .Delta.Bucket buckets = 1;
repeated string classes = 5;
repeated string confirms = 7;
repeated .Delta.Entry content = 3;
repeated string allHashes = 3;
repeated string allHashes = 2;
repeated string allHashes = 3;
repeated string allHashes = 2;
repeated .Member members = 4;
repeated string allMetricNames = 2;
repeated string allMetricNames = 2;
repeated .NodeMetrics.Metric metrics = 3;
repeated fixed64 nacks = 2;
repeated .NodeMetrics nodeMetrics = 3;
repeated .ObserverReachability observerReachability = 2;
repeated .Selection pattern = 3;
repeated string allRoles = 2;
repeated string roles = 2;
repeated string allRoles = 2;
repeated int32 rolesIndexes = 4 [packed = true];
repeated int32 seen = 1;
repeated .SubjectReachability subjectReachability = 2;
repeated .AtLeastOnceDeliverySnapshot.UnconfirmedDelivery unconfirmedDeliveries = 2;
repeated .VectorClock.Version versions = 2;
repeated .Status.Version versions = 1;
repeated bytes args = 4;
repeated .PersistentMessage batch = 1;
repeated .PersistentMessage batch = 1;
repeated .PersistentMessage batch = 1;
repeated .PersistentMessage batch = 1;
repeated .PersistentMessage batch = 1;
repeated .PersistentMessage batch = 1;
repeated .Delta.Bucket buckets = 1;
repeated .Delta.Bucket buckets = 1;
repeated .Delta.Bucket buckets = 1;
repeated .Delta.Bucket buckets = 1;
repeated .Delta.Bucket buckets = 1;
repeated .Delta.Bucket buckets = 1;
repeated string classes = 5;
repeated string classes = 5;
repeated string confirms = 7;
repeated string confirms = 7;
repeated .Delta.Entry content = 3;
repeated .Delta.Entry content = 3;
repeated .Delta.Entry content = 3;
repeated .Delta.Entry content = 3;
repeated .Delta.Entry content = 3;
repeated .Delta.Entry content = 3;
repeated .Member members = 4;
repeated .Member members = 4;
repeated .Member members = 4;
repeated .Member members = 4;
repeated .Member members = 4;
repeated .Member members = 4;
repeated .NodeMetrics.Metric metrics = 3;
repeated .NodeMetrics.Metric metrics = 3;
repeated .NodeMetrics.Metric metrics = 3;
repeated .NodeMetrics.Metric metrics = 3;
repeated .NodeMetrics.Metric metrics = 3;
repeated .NodeMetrics.Metric metrics = 3;
repeated fixed64 nacks = 2;
repeated .NodeMetrics nodeMetrics = 3;
repeated .NodeMetrics nodeMetrics = 3;
repeated .NodeMetrics nodeMetrics = 3;
repeated .NodeMetrics nodeMetrics = 3;
repeated .NodeMetrics nodeMetrics = 3;
repeated .NodeMetrics nodeMetrics = 3;
repeated .ObserverReachability observerReachability = 2;
repeated .ObserverReachability observerReachability = 2;
repeated .ObserverReachability observerReachability = 2;
repeated .ObserverReachability observerReachability = 2;
repeated .ObserverReachability observerReachability = 2;
repeated .ObserverReachability observerReachability = 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;
Address ordering type class, sorts addresses by host and port.
Address ordering type class, sorts addresses by host and port.
Int.repeated string roles = 2;
repeated string roles = 2;
repeated int32 rolesIndexes = 4 [packed = true];
RoutingLogic.
ActorRefRoutee for the
specified ActorRef and the same RoutingLogic.
ActorSelectionRoutee for the
specified ActorSelection and the same RoutingLogic.
Router.
repeated int32 seen = 1;
repeated .SubjectReachability subjectReachability = 2;
repeated .SubjectReachability subjectReachability = 2;
repeated .SubjectReachability subjectReachability = 2;
repeated .SubjectReachability subjectReachability = 2;
repeated .SubjectReachability subjectReachability = 2;
repeated .SubjectReachability subjectReachability = 2;
repeated .AtLeastOnceDeliverySnapshot.UnconfirmedDelivery unconfirmedDeliveries = 2;
repeated .AtLeastOnceDeliverySnapshot.UnconfirmedDelivery unconfirmedDeliveries = 2;
repeated .AtLeastOnceDeliverySnapshot.UnconfirmedDelivery unconfirmedDeliveries = 2;
repeated .AtLeastOnceDeliverySnapshot.UnconfirmedDelivery unconfirmedDeliveries = 2;
repeated .AtLeastOnceDeliverySnapshot.UnconfirmedDelivery unconfirmedDeliveries = 2;
repeated .AtLeastOnceDeliverySnapshot.UnconfirmedDelivery unconfirmedDeliveries = 2;
repeated .VectorClock.Version versions = 2;
repeated .VectorClock.Version versions = 2;
repeated .VectorClock.Version versions = 2;
repeated .VectorClock.Version versions = 2;
repeated .Status.Version versions = 1;
repeated .Status.Version versions = 1;
repeated .Status.Version versions = 1;
repeated .Status.Version versions = 1;
repeated .VectorClock.Version versions = 2;
repeated .VectorClock.Version versions = 2;
repeated .Status.Version versions = 1;
repeated .Status.Version versions = 1;
Pool.Affinity option shall set the I/O thread affinity for newly created connections on the specified socket.Affinity valueFuture that will be completed with the success or failure of the provided value
after the specified duration.
Future that will be completed with the success or failure of the provided Callable
after the specified duration.
Future that will be completed with the success or failure of the provided value
after the specified duration.
Future that will be completed with the success or failure of the provided Callable
after the specified duration.
Future that will be completed with the success or failure of the provided value
after the specified duration.
Directive (Resume, Restart, Stop) specified in the Decider
to all children when one fails, as opposed to OneForOneStrategy that applies
it only to the child actor that failed.EWMA
from specified half-life and interval between observations.
ActorPath of the anchor actor.
WriteCommand to form a CompoundWrite.
LogSource, generate the
string representation and originating class.
LogSource and
ActorSystem, generate the string representation and
originating class.
Tcp or Udp.
Tcp or Udp.
WriteCommand.
FailureDetector implementation.
FailureDetector implementation.
postRestart.
postStop.
preRestart.
preStart.
? and ask methods on
ActorRef, which will defer to the
ask(actorRef, message)(timeout) method defined here.
Future
holding the eventual reply message; this means that the target actor
needs to send the result to the sender reference provided.
? and ask methods on
ActorSelection, which will defer to the
ask(actorSelection, message)(timeout) method defined here.
Future
holding the eventual reply message; this means that the target actor
needs to send the result to the sender reference provided.
akka.pattern.ask:
Sends a message asynchronously and returns a Future
holding the eventual reply message; this means that the target actor
needs to send the result to the sender reference provided.
akka.pattern.ask:
Sends a message asynchronously and returns a Future
holding the eventual reply message; this means that the target actor
needs to send the result to the sender reference provided.
akka.pattern.ask:
Sends a message asynchronously and returns a Future
holding the eventual reply message; this means that the target ActorSelection
needs to send the result to the sender reference provided.
akka.pattern.ask:
Sends a message asynchronously and returns a Future
holding the eventual reply message; this means that the target ActorSelection
needs to send the result to the sender reference provided.
akka.pattern.ask:
Sends a message asynchronously and returns a Future
holding the eventual reply message; this means that the target actor
needs to send the result to the sender reference provided.
akka.pattern.ask:
Sends a message asynchronously and returns a Future
holding the eventual reply message; this means that the target actor
needs to send the result to the sender reference provided.
akka.pattern.ask:
Sends a message asynchronously and returns a Future
holding the eventual reply message; this means that the target ActorSelection
needs to send the result to the sender reference provided.
akka.pattern.ask:
Sends a message asynchronously and returns a Future
holding the eventual reply message; this means that the target ActorSelection
needs to send the result to the sender reference provided.
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.messageIds from the
journal.
toSequenceNr
(inclusive).
persistenceId.
PersistentActor to send messages with at-least-once
delivery semantics to destinations.AtLeastOnceDelivery state.java.lang.Runnable.
java.util.concurrent.Callable.
true, this view automatically updates itself with an interval specified by autoUpdateInterval.
true, this view automatically updates itself with an interval specified by autoUpdateInterval.
true or the timeout
expires, whichever comes first.
true or the timeout
expires, whichever comes first.
true or the timeout
expires, whichever comes first.
.await() onto all Awaitables, using remaining duration from the innermost
enclosing within block or QueryTimeout.
Backlog option shall set the maximum length of the queue of outstanding peer connections
for the specified socket; this only applies to connection-oriented transports.backoffThreshold and backoffRate
BalancingDispatcher.Runnable.run() calls
into a single Runnable passed to the original
Executor.TcpExt.getManager() in order to bind to a listening socket.
TcpExt.getManager() in order to bind to a listening socket.
UdpExt.manager() in order to bind to the given
local port (or an automatically assigned one if the port number is zero).
UdpExt.manager() in order to bind to the given
local port (or an automatically assigned one if the port number is zero).
T.
Both = 3;
Inet.SocketOption to set the SO_BROADCAST option
Inet.SocketOption to set the SO_BROADCAST option
PartialFunction from this builder.
PartialFunction from this builder.
PartialFunction from this builder.
LoggingAdapter that publishes Logging.LogEvent to event stream.ByteString.CircuitBreaker.withCircuitBreaker(scala.Function0>)
CircuitBreaker.withSyncCircuitBreaker(scala.Function0)
Camel trait which provides access to the CamelExtension.
org.apache.camel.Exchange to and from CamelMessage and akka.camel.Failure objects.FSM.cancelTimer(java.lang.String).
msg.
msg.
Processors (and Views) for sending Persistent messages to destinations.register on the ChannelRegistry.Channel configuration object.CHILD_NAME = 1;
CHILD_PATTERN = 2;
optional .AcknowledgementInfo ack = 1;
optional .Address addr = 2;
optional .AddressRequest addr = 5;
required .Address address = 1;
required .Address address = 1;
required .Address address = 2;
optional .Address address = 3;
required int32 addressIndex = 1;
required int32 addressIndex = 1;
required int32 addressIndex = 1;
required int32 addressIndex = 1;
repeated .UniqueAddress allAddresses = 1;
repeated .Address allAddresses = 1;
required bool allButSelf = 2;
repeated string allHashes = 3;
repeated string allHashes = 2;
repeated string allMetricNames = 2;
repeated string allRoles = 2;
required double alpha = 2;
repeated bytes args = 4;
optional .EnterBarrier barrier = 2;
repeated .PersistentMessage batch = 1;
repeated .Delta.Bucket buckets = 1;
optional string channel = 5;
optional string channelId = 2;
repeated string classes = 5;
required string clazz = 3;
required .CommandType commandType = 1;
optional bytes config = 2;
optional bool confirmable = 8;
optional .DeliveredMessage confirmMessage = 9;
repeated string confirms = 7;
optional string confirmTarget = 10;
repeated .Delta.Entry content = 3;
optional string cookie = 3;
required fixed64 cumulativeAck = 1;
required int64 currentDeliveryId = 1;
optional bool deleted = 4;
required int64 deliveryId = 1;
optional int64 deliverySequenceNr = 4;
required .DeployData deploy = 2;
required .DeployData deploy = 2;
required string destination = 2;
optional string destination = 2;
optional .Direction direction = 2;
optional string dispatcher = 5;
optional string done = 4;
required bytes enclosedMessage = 1;
required bytes enclosedMessage = 1;
optional .RemoteEnvelope envelope = 2;
optional .NodeMetrics.EWMA ewma = 3;
optional int32 exitValue = 7;
required .FailType failure = 1;
optional .InjectFailure failure = 3;
required .UniqueAddress from = 1;
required .UniqueAddress from = 1;
required .Address from = 1;
required .UniqueAddress from = 1;
required .MetricsGossip gossip = 2;
required .Gossip gossip = 2;
optional .AkkaHandshakeInfo handshakeInfo = 2;
required int32 hashIndex = 1;
optional .Hello hello = 1;
required string host = 3;
required string hostname = 2;
required string hostname = 2;
required string hostname = 2;
optional .AkkaControlMessage instruction = 2;
required string key = 1;
required bool localAffinity = 2;
optional string matcher = 2;
repeated .Member members = 4;
required .SerializedMessage message = 2;
required bytes message = 1;
optional bytes messageManifest = 4;
optional bytes messageManifest = 4;
optional bytes messageManifest = 3;
repeated .NodeMetrics.Metric metrics = 3;
repeated fixed64 nacks = 2;
required string name = 1;
required string name = 1;
required int32 nameIndex = 1;
required .UniqueAddress node = 1;
required string node = 1;
repeated .NodeMetrics nodeMetrics = 3;
required .NodeMetrics.Number number = 2;
repeated .ObserverReachability observerReachability = 2;
required .BarrierOp op = 2;
required .AddressData origin = 1;
required .GossipOverview overview = 5;
required .Address owner = 1;
required string path = 1;
required string path = 1;
required string path = 1;
required string path = 3;
required string path = 1;
repeated .Selection pattern = 3;
required .Payload payload = 3;
required .Payload payload = 3;
required .Payload payload = 3;
required .PersistentPayload payload = 3;
optional .PersistentPayload payload = 1;
required bytes payload = 2;
optional bytes payload = 1;
optional bytes payloadManifest = 3;
optional string persistenceId = 1;
optional string persistenceId = 3;
optional .PersistentMessage persistent = 1;
optional int64 persistentSequenceNr = 3;
required uint32 port = 3;
required uint32 port = 3;
required int32 port = 4;
required uint32 port = 3;
required .PropsData props = 1;
optional string protocol = 4;
optional string protocol = 4;
required string protocol = 1;
optional string protocol = 4;
optional float rateMBit = 6;
required .ActorRefData recipient = 1;
optional int32 redeliveries = 6;
optional string ref = 3;
required bool reply = 3;
repeated string roles = 2;
repeated int32 rolesIndexes = 4 [packed = true];
optional bytes routerConfig = 3;
optional bytes scope = 4;
repeated int32 seen = 1;
optional string sender = 11;
optional .ActorRefData sender = 4;
optional fixed64 seq = 5;
optional int64 sequenceNr = 2;
optional bytes serialized = 4;
required bytes serializedGossip = 3;
required int32 serializerId = 2;
required int32 serializerId = 1;
required int32 serializerId = 2;
required int32 serializerId = 2;
required .MemberStatus status = 3;
required .ReachabilityStatus status = 3;
repeated .SubjectReachability subjectReachability = 2;
required .ActorRefData supervisor = 4;
required string system = 1;
required string system = 1;
required string system = 2;
required string system = 1;
optional int64 timeout = 3;
required int64 timestamp = 2;
optional int64 timestamp = 1;
required int64 timestamp = 2;
required int64 timestamp = 2;
required .UniqueAddress to = 2;
required string topic = 1;
required .NodeMetrics.NumberType type = 1;
required .PatternType type = 1;
required uint32 uid = 2;
required fixed64 uid = 2;
repeated .AtLeastOnceDeliverySnapshot.UnconfirmedDelivery unconfirmedDeliveries = 2;
required int32 upNumber = 2;
required double value = 1;
optional uint32 value32 = 2;
optional uint64 value64 = 3;
required .VectorClock version = 6;
required .VectorClock version = 3;
required int64 version = 4;
required int64 version = 4;
required int64 version = 2;
required int64 version = 2;
repeated .VectorClock.Version versions = 2;
repeated .Status.Version versions = 1;
optional bool wildcardFanOut = 5;
Player
side: in a first step it registers itself with a symbolic name and its remote
address at the Controller, then waits for the
Done message which signals that all other expected test participants have
done the same.localAffinity false
ClusterEvent.MemberRemoved events are published.ClusterEvent.CurrentClusterState will be sent to the
subscriber as the first message.MemberStatus.Exiting and will be removed
when all members have seen the Exiting status.ClusterEvent.UnreachableMember and ClusterEvent.ReachableMember.ClusterHeartbeatSender.Heartbeat messages.ClusterHeartbeatSender.AddressAddressEmptyEmptyGossipGossipGossipEnvelopeGossipEnvelopeGossipOverviewGossipOverviewGossipStatusGossipStatusJoinJoinMemberMemberMemberStatusMetricsGossipMetricsGossipMetricsGossipEnvelopeMetricsGossipEnvelopeNodeMetricsNodeMetricsNodeMetrics.EWMANodeMetrics.EWMANodeMetrics.MetricNodeMetrics.MetricNodeMetrics.NumberNodeMetrics.NumberNodeMetrics.NumberTypeObserverReachabilityObserverReachabilityReachabilityStatusSubjectReachabilitySubjectReachabilityUniqueAddressUniqueAddressVectorClockVectorClockVectorClock.VersionVectorClock.VersionWelcomeWelcomeClusterClient connects to this actor to retrieve.ClusterReceptionist and accompanying DistributedPubSubMediator
with settings defined in config section akka.contrib.cluster.receptionist.RouterConfig implementation for deployment on cluster nodes.RouterConfig implementation for deployment on cluster nodes.Deploywith FSM type parameterswith FSM type parametersClusterSingletonProxy works together with the ClusterSingletonManager to provide a
distributed proxy to the singleton actor.Cluster extension
or JMX.Cluster extension
or JMX.address).MetricsGossip, and publishes the change to the event bus.
Controller’s port to which all
Players connect, it issues commands to their
akka.remote.testconductor.NetworkFailureInjector and provides support
for barriers using the BarrierCoordinator.Channel and PersistentChannel destinations to confirm the receipt of a
persistent message.
true only if this message has been delivered by a channel.
Channel or PersistentChannel.TcpExt.getManager().
remoteAddress without binding to a local address and without
specifying options.
TcpExt.getManager().
remoteAddress without binding to a local address and without
specifying options.
UdpExt.manager() in order to bind to a local
port (optionally with the chosen localAddress) and create a UDP socket
which is restricted to sending to and receiving from the given remoteAddress.
localAddress.
localAddress or options.
UdpExt.manager() in order to bind to a local
port (optionally with the chosen localAddress) and create a UDP socket
which is restricted to sending to and receiving from the given remoteAddress.
localAddress.
localAddress or options.
hashMapping when
constructing the ConsistentHashingRouter
the messages need to implement this interface to define what
data to use for the consistent hash key.hashMapping when
constructing the ConsistentHashingRouter
and messages can't implement ConsistentHashingRouter.ConsistentHashable
themselves they can we wrapped by this envelope instead.PatternTypeSelectionSelectionSelectionEnvelopeSelectionEnvelopeBarrierCoordinator, its child) and allowing
network and other failures to be injected at the test nodes.Coordinated is a message wrapper that adds a CommitBarrier for explicitly
coordinating transactions across actors or threads.watch.