|
|||||||||
| 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.Creator.
Creator with the type set to the given actorClass.
Creator.
Creator with the type set to the given actorClass.
WriteCommand.
Match from the builder.
UnitMatch from the builder.
ActorSystem, using the name specified
ActorSystem, using the name specified.
Class[_] object and a constructor description
will create a new instance of that class.
args argument.
RouterConfig
Actor with Stash,
since just using actor()(new Act with Stash{}) will not be able to see the
Stash component due to type erasure.Group nor
a Pool it may extend this base class.DeadLetter.source, if given, applies a filter on the event’s origin
message applies a filter on the event’s message (either with String.startsWith or Regex.findFirstIn().isDefined)
If you want to match all Debug events, the most efficient is to use Left("").Actor.supervisorStrategy().AkkaPduCodec.AkkaPdu instance that represents the PDU contained in the raw
ByteString.
ContextProvider
Provides a new DefaultCamelContext per actor systemDecider is used by default in the supervisor strategy.
Decider is used by default in the supervisor strategy.
FailureDetectorRegistry.ClusterClient Props with
default values.
ClusterClient Props with
default values.
ClusterSingletonManager Props
with default values.
ClusterSingletonManager Props
with default values.
ClusterSingletonProxy Props.
ClusterSingletonProxy Props.
DistributedPubSubMediator Props
with default values.
DistributedPubSubMediator Props
with default values.
metadata.
criteria.
true if this message is marked as deleted.
sequenceNr, as deleted.
sequenceNr.
messageIds from the
journal.
toSequenceNr.
toSequenceNr.
toSequenceNr
(inclusive).
sequenceNr and timestamp.
criteria.
deliveryIdToMessage function to
the destination actor.
deliveryIdToMessage function to
the destination actor.
Channel or PersistentChannel to deliver a persistent message to
a destination.deliveryIdToMessage function to
the destination actor.
ConfirmablePersistent messages
by calling ConfirmablePersistent.confirm().ActorRef
from Akka's protobuf representation in the supplied
ActorSystem.
ActorRef
from Akka's protobuf representation in the supplied
ActorSystem.
DISASSOCIATE_QUARANTINED = 5;
DISASSOCIATE_SHUTTING_DOWN = 4;
DISASSOCIATE = 2;
TestTransport.SwitchableLoggedBehavior for the disassociate() method on handles.
UdpConnected.Connected message) in order to close the socket.
UdpConnected.Connected message) in order to close the socket.
Disconnect = 2;
Deploy instance.
BlockingQueue.Dispatcher.DistributedPubSubMediator actor
with settings defined in config section akka.contrib.cluster.pub-sub.localAffinity false
group None
AddressAddressDeltaDelta.BucketDelta.BucketDeltaDelta.EntryDelta.EntryPayloadPayloadPublishPublishSendSendSendToAllSendToAllStatusStatusStatus.VersionStatus.VersionDouble = 1;
Down = 4;
Logging.LogEvent when the string representation was supplied
directly.DurationDurationReflectiveDynamicAccess is the default implementation).AkkaPduCodec.AkkaPdu representation of an Akka PDU and returns its encoded
form as a ByteString.
envelope at the first position in the mailbox.
Enter = 1;
message.
message.
throwable applies an upper bound on the type of exception contained in the Error event
source, if given, applies a filter on the event’s origin
message applies a filter on the event’s message (either
with String.startsWith or Regex.findFirstIn().isDefined); if the message
itself does not match, the match is retried with the contained Exception’s
message; if both are null, the filter always matches if at
the same time the Exception’s stack trace is empty (this catches
JVM-omitted “fast-throw” exceptions)
If you want to match all Error events, the most efficient is to use Left("").EventBus
E is the Event type
S is the Subscriber type
C is the Classifier typeExit = 4;
Exiting = 3;
expectMsg(remaining, obj), but correctly treating the timeFactor.
expectMsgAllClassOf(remaining, obj...), but correctly treating the timeFactor.
expectMsgAllConformingOf(remaining, obj...), but correctly treating the timeFactor.
expectMsgAllOf(remaining(), obj...), but correctly
treating the timeFactor.
expectMsgAllOf(remaining, obj...), but correctly treating the timeFactor.
expectMsgAnyClassOf(remaining(), obj...), but
correctly treating the timeFactor.
expectMsgAnyClassOf(remaining, obj...), but correctly treating the timeFactor.
expectMsgAnyOf(remaining(), obj...), but correctly
treating the timeFactor.
expectMsgAnyOf(remaining, obj...), but correctly treating the timeFactor.
expectMsgClass(remaining(), clazz), but correctly
treating the timeFactor.
expectMsgClass(remaining, c), but correctly treating the timeFactor.
expectMsgEquals(remaining(), obj), but correctly
treating the timeFactor.
expectMsgType[T](remaining), but correctly treating the timeFactor.
expectNoMsg(remaining()), but correctly treating the
timeFactor.
expectNoMsg(remaining), but correctly treating the timeFactor.
expectTerminated(remaining(), target),
but correctly treating the timeFactor.
Extension).Fail = 2;
Failed = 4;
includeNodes Set.
Float = 2;
Class’s simple name.
Class’s simple name.
PersistentBatch, PersistentRepr and Deliver messages.
Snapshot.
ActorEndpointPath from the uri
Expects the uri in the akka ActorPath format, i.e 'akka://system/user/someactor'.
ActorEndpointPath from the uri
Expects the uri in the akka ActorPath format, i.e 'akka://system/user/someactor'.
FSM.SubscribeTransitionCallBack before sending any
FSM.Transition messages.FSM will be wrapped inside an
Event, which allows pattern matching to extract both state and data.FSM is shutting itself down because of
an error, e.g.LoggingFSM, can be obtained by calling getLog.stop().whenUnhandled and onTermination handlers.FSM is shutting down.system.stop(fsm) from outside;
also applies to Stop supervision directive.FSM: the state
name, the state data, possibly custom timeout, stop reason and replies
accumulated while processing the last message.FSM whithin the
onTermination block.FSM to request first the FSM.CurrentState
and then a series of FSM.Transition updates.FSM.SubscribeTransitionCallBack).FSM.Transition notifications which was
effected by sending the corresponding FSM.SubscribeTransitionCallBack.FSM.whenUnhandled(scala.PartialFunction, akka.actor.FSM.State>) .FSM.onTermination(scala.PartialFunction, scala.runtime.BoxedUnit>) .FSM.onTransition(scala.PartialFunction, scala.runtime.BoxedUnit>) .Future object with the result of that computation.
Future object with the result of that computation.
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;
Activation interface
that can be used to wait on activation or de-activation of Camel endpoints.
Activation interface
that can be used to wait on activation or de-activation of Camel endpoints.
ActorSystem instance.
ActorSystem name will be set to bundle--ActorSystem .
optional .Address addr = 2;
optional .Address addr = 2;
optional .Address addr = 2;
optional .AddressRequest addr = 5;
optional .AddressRequest addr = 5;
optional .AddressRequest addr = 5;
optional .Address addr = 2;
optional .AddressRequest addr = 5;
required .Address address = 1;
required .Address address = 1;
required .Address address = 1;
required .Address address = 1;
required .Address address = 1;
required .Address address = 1;
required .Address address = 2;
required .Address address = 2;
required .Address address = 2;
optional .Address address = 3;
optional .Address address = 3;
optional .Address address = 3;
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;
required int32 addressIndex = 1;
required int32 addressIndex = 1;
required int32 addressIndex = 1;
required int32 addressIndex = 1;
required int32 addressIndex = 1;
required int32 addressIndex = 1;
required int32 addressIndex = 1;
required int32 addressIndex = 1;
required .Address address = 1;
required .Address address = 1;
required .Address address = 1;
required .Address address = 1;
required .Address address = 1;
required .Address address = 1;
required .Address address = 2;
required .Address address = 2;
required .Address address = 2;
optional .Address address = 3;
optional .Address address = 3;
optional .Address address = 3;
optional .Address addr = 2;
optional .Address addr = 2;
optional .Address addr = 2;
optional .AddressRequest addr = 5;
optional .AddressRequest addr = 5;
optional .AddressRequest addr = 5;
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 .UniqueAddress allAddresses = 1;
repeated .Address allAddresses = 1;
repeated .UniqueAddress allAddresses = 1;
repeated .Address 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 .UniqueAddress allAddresses = 1;
repeated .UniqueAddress allAddresses = 1;
repeated .UniqueAddress allAddresses = 1;
repeated .Address allAddresses = 1;
repeated .Address allAddresses = 1;
repeated .Address 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 .UniqueAddress allAddresses = 1;
repeated .UniqueAddress allAddresses = 1;
repeated .UniqueAddress allAddresses = 1;
repeated .Address allAddresses = 1;
repeated .Address allAddresses = 1;
repeated .Address allAddresses = 1;
required bool allButSelf = 2;
required bool allButSelf = 2;
required bool allButSelf = 2;
repeated string allHashes = 3;
repeated string allHashes = 3;
repeated string allHashes = 3;
repeated string allHashes = 2;
repeated string allHashes = 2;
repeated string allHashes = 2;
repeated string allHashes = 3;
repeated string allHashes = 3;
repeated string allHashes = 3;
repeated string allHashes = 2;
repeated string allHashes = 2;
repeated string allHashes = 2;
repeated string allHashes = 3;
repeated string allHashes = 3;
repeated string allHashes = 3;
repeated string allHashes = 2;
repeated string allHashes = 2;
repeated string allHashes = 2;
repeated string allHashes = 3;
repeated string allHashes = 3;
repeated string allHashes = 3;
repeated string allHashes = 2;
repeated string allHashes = 2;
repeated string allHashes = 2;
repeated string allMetricNames = 2;
repeated string allMetricNames = 2;
repeated string allMetricNames = 2;
repeated string allMetricNames = 2;
repeated string allMetricNames = 2;
repeated string allMetricNames = 2;
repeated string allMetricNames = 2;
repeated string allMetricNames = 2;
repeated string allMetricNames = 2;
repeated string allMetricNames = 2;
repeated string allMetricNames = 2;
repeated string allMetricNames = 2;
repeated string allRoles = 2;
repeated string allRoles = 2;
repeated string allRoles = 2;
repeated string allRoles = 2;
repeated string allRoles = 2;
repeated string allRoles = 2;
repeated string allRoles = 2;
repeated string allRoles = 2;
repeated string allRoles = 2;
repeated string allRoles = 2;
repeated string allRoles = 2;
repeated string allRoles = 2;
required double alpha = 2;
required double alpha = 2;
required double alpha = 2;
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;
optional .EnterBarrier barrier = 2;
optional .EnterBarrier barrier = 2;
optional .EnterBarrier barrier = 2;
optional .EnterBarrier barrier = 2;
optional .EnterBarrier barrier = 2;
optional .EnterBarrier barrier = 2;
optional .EnterBarrier barrier = 2;
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 .PersistentMessage batch = 1;
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 .PersistentMessage batch = 1;
repeated .PersistentMessage batch = 1;
repeated .PersistentMessage batch = 1;
repeated .PersistentMessage batch = 1;
clazz
parameter.
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 .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 .Delta.Bucket buckets = 1;
repeated .Delta.Bucket buckets = 1;
repeated .Delta.Bucket buckets = 1;
repeated .Delta.Bucket buckets = 1;
repeated .Delta.Bucket buckets = 1;
Class[_] object for the code
executing in that stack frame.
Class[_] object for the code
executing in that stack frame.
org.apache.camel.impl.DefaultCamelContext
CamelContext.
optional string channel = 5;
optional string channel = 5;
optional string channel = 5;
optional string channel = 5;
optional string channel = 5;
optional string channel = 5;
optional string channelId = 2;
optional string channelId = 2;
optional string channelId = 2;
optional string channelId = 2;
optional string channelId = 2;
optional string channelId = 2;
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;
Class[_] object loaded with the right class loader (i.e.
required string clazz = 3;
required string clazz = 3;
required string clazz = 3;
required string clazz = 3;
required string clazz = 3;
required string clazz = 3;
ClusterShuttingDown event
ClusterShuttingDown event
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 bool confirmable = 8;
optional bool confirmable = 8;
optional bool confirmable = 8;
optional .DeliveredMessage confirmMessage = 9;
optional .DeliveredMessage confirmMessage = 9;
optional .DeliveredMessage confirmMessage = 9;
optional .DeliveredMessage confirmMessage = 9;
optional .DeliveredMessage confirmMessage = 9;
optional .DeliveredMessage confirmMessage = 9;
optional .DeliveredMessage confirmMessage = 9;
repeated string confirms = 7;
repeated string confirms = 7;
repeated string confirms = 7;
repeated string confirms = 7;
repeated string confirms = 7;
repeated string confirms = 7;
repeated string confirms = 7;
repeated string confirms = 7;
repeated string confirms = 7;
repeated string confirms = 7;
repeated string confirms = 7;
repeated string confirms = 7;
optional string confirmTarget = 10;
optional string confirmTarget = 10;
optional string confirmTarget = 10;
optional string confirmTarget = 10;
optional string confirmTarget = 10;
optional string confirmTarget = 10;
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 .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 .Delta.Entry content = 3;
repeated .Delta.Entry content = 3;
repeated .Delta.Entry content = 3;
repeated .Delta.Entry content = 3;
repeated .Delta.Entry content = 3;
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 int64 currentDeliveryId = 1;
required int64 currentDeliveryId = 1;
required int64 currentDeliveryId = 1;
null if there is none.
optional bool deleted = 4;
optional bool deleted = 4;
optional bool deleted = 4;
required int64 deliveryId = 1;
required int64 deliveryId = 1;
required int64 deliveryId = 1;
optional int64 deliverySequenceNr = 4;
optional int64 deliverySequenceNr = 4;
optional int64 deliverySequenceNr = 4;
AtLeastOnceDelivery.
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;
required string destination = 2;
required string destination = 2;
required string destination = 2;
optional string destination = 2;
optional string destination = 2;
optional string destination = 2;
required string destination = 2;
required string destination = 2;
required string destination = 2;
optional string destination = 2;
optional string destination = 2;
optional string destination = 2;
optional .Direction direction = 2;
optional .Direction direction = 2;
optional .Direction direction = 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;
optional string done = 4;
optional string done = 4;
optional string done = 4;
optional string done = 4;
optional string done = 4;
optional string done = 4;
required bytes enclosedMessage = 1;
required bytes enclosedMessage = 1;
required bytes enclosedMessage = 1;
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;
isErrorClosed returns true, then the error condition can be
retrieved by this method.
optional .NodeMetrics.EWMA ewma = 3;
optional .NodeMetrics.EWMA ewma = 3;
optional .NodeMetrics.EWMA ewma = 3;
optional .NodeMetrics.EWMA ewma = 3;
optional .NodeMetrics.EWMA ewma = 3;
optional .NodeMetrics.EWMA ewma = 3;
optional .NodeMetrics.EWMA ewma = 3;
optional int32 exitValue = 7;
optional int32 exitValue = 7;
optional int32 exitValue = 7;
required .FailType failure = 1;
required .FailType failure = 1;
required .FailType failure = 1;
optional .InjectFailure failure = 3;
optional .InjectFailure failure = 3;
optional .InjectFailure failure = 3;
optional .InjectFailure failure = 3;
optional .InjectFailure failure = 3;
optional .InjectFailure failure = 3;
optional .InjectFailure failure = 3;
required .UniqueAddress from = 1;
required .UniqueAddress from = 1;
required .UniqueAddress from = 1;
required .UniqueAddress from = 1;
required .UniqueAddress from = 1;
required .UniqueAddress from = 1;
required .Address from = 1;
required .Address from = 1;
required .Address from = 1;
required .UniqueAddress from = 1;
required .UniqueAddress from = 1;
required .UniqueAddress from = 1;
required .UniqueAddress from = 1;
required .UniqueAddress from = 1;
required .Address from = 1;
required .UniqueAddress from = 1;
required .UniqueAddress from = 1;
required .UniqueAddress from = 1;
required .UniqueAddress from = 1;
required .UniqueAddress from = 1;
required .UniqueAddress from = 1;
required .UniqueAddress from = 1;
required .Address from = 1;
required .Address from = 1;
required .Address from = 1;
required .UniqueAddress from = 1;
required .UniqueAddress from = 1;
required .UniqueAddress from = 1;
required .MetricsGossip gossip = 2;
required .MetricsGossip gossip = 2;
required .MetricsGossip gossip = 2;
required .Gossip gossip = 2;
required .Gossip gossip = 2;
required .Gossip gossip = 2;
required .MetricsGossip gossip = 2;
required .Gossip gossip = 2;
required .MetricsGossip gossip = 2;
required .MetricsGossip gossip = 2;
required .MetricsGossip gossip = 2;
required .Gossip gossip = 2;
required .Gossip gossip = 2;
required .Gossip gossip = 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 int32 hashIndex = 1;
required int32 hashIndex = 1;
required int32 hashIndex = 1;
name parameter.
names.
optional .Hello hello = 1;
optional .Hello hello = 1;
optional .Hello hello = 1;
optional .Hello hello = 1;
optional .Hello hello = 1;
optional .Hello hello = 1;
optional .Hello hello = 1;
required string host = 3;
required string host = 3;
required string host = 3;
required string host = 3;
required string host = 3;
required string host = 3;
required string hostname = 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;
required string hostname = 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;
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;
required string key = 1;
required string key = 1;
required string key = 1;
required string key = 1;
required string key = 1;
required string key = 1;
required bool localAffinity = 2;
required bool localAffinity = 2;
required bool localAffinity = 2;
n
bytes were encoded.
optional string matcher = 2;
optional string matcher = 2;
optional string matcher = 2;
optional string matcher = 2;
optional string matcher = 2;
optional string matcher = 2;
Slf4jLogger is configured.
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 .Member members = 4;
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 .Member members = 4;
repeated .Member members = 4;
repeated .Member members = 4;
repeated .Member members = 4;
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 = 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 .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 .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 .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 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 string name = 1;
required string name = 1;
required string name = 1;
required string name = 1;
required string name = 1;
required string name = 1;
required string name = 1;
required string name = 1;
required string name = 1;
required string name = 1;
required string name = 1;
required string name = 1;
required int32 nameIndex = 1;
required int32 nameIndex = 1;
required int32 nameIndex = 1;
required .UniqueAddress node = 1;
required .UniqueAddress node = 1;
required .UniqueAddress node = 1;
required string node = 1;
required string node = 1;
required string node = 1;
required .UniqueAddress node = 1;
required string node = 1;
required string node = 1;
required string node = 1;
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 .NodeMetrics nodeMetrics = 3;
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 .NodeMetrics nodeMetrics = 3;
repeated .NodeMetrics nodeMetrics = 3;
repeated .NodeMetrics nodeMetrics = 3;
repeated .NodeMetrics nodeMetrics = 3;
required .UniqueAddress node = 1;
required .UniqueAddress node = 1;
required .UniqueAddress node = 1;
required .NodeMetrics.Number number = 2;
required .NodeMetrics.Number number = 2;
required .NodeMetrics.Number number = 2;
required .NodeMetrics.Number number = 2;
required .NodeMetrics.Number number = 2;
required .NodeMetrics.Number number = 2;
required .NodeMetrics.Number number = 2;
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 .ObserverReachability observerReachability = 2;
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 .ObserverReachability observerReachability = 2;
repeated .ObserverReachability observerReachability = 2;
repeated .ObserverReachability observerReachability = 2;
repeated .ObserverReachability observerReachability = 2;
required .BarrierOp op = 2;
required .BarrierOp op = 2;
required .BarrierOp op = 2;
a if this is some(a) or defaultValue if
this is none.
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 .GossipOverview overview = 5;
required .GossipOverview overview = 5;
required .GossipOverview overview = 5;
required .GossipOverview overview = 5;
required .GossipOverview overview = 5;
required .GossipOverview overview = 5;
required .GossipOverview overview = 5;
required .Address owner = 1;
required .Address owner = 1;
required .Address owner = 1;
required .Address owner = 1;
required .Address owner = 1;
required .Address owner = 1;
required .Address owner = 1;
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 = 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 = 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;
required .Payload payload = 3;
required .Payload payload = 3;
required .Payload payload = 3;
required .Payload payload = 3;
required .Payload payload = 3;
required .Payload payload = 3;
required .Payload payload = 3;
required .Payload payload = 3;
required .Payload payload = 3;
required .PersistentPayload payload = 3;
required .PersistentPayload payload = 3;
required .PersistentPayload payload = 3;
optional .PersistentPayload payload = 1;
optional .PersistentPayload payload = 1;
optional .PersistentPayload payload = 1;
required bytes payload = 2;
required bytes payload = 2;
required bytes payload = 2;
optional bytes payload = 1;
optional bytes payload = 1;
optional bytes payload = 1;
required .Payload payload = 3;
required .Payload payload = 3;
required .Payload payload = 3;
required .PersistentPayload payload = 3;
optional .PersistentPayload payload = 1;
optional bytes payloadManifest = 3;
optional bytes payloadManifest = 3;
optional bytes payloadManifest = 3;
required .Payload payload = 3;
required .Payload payload = 3;
required .Payload payload = 3;
required .Payload payload = 3;
required .Payload payload = 3;
required .Payload payload = 3;
required .Payload payload = 3;
required .Payload payload = 3;
required .Payload payload = 3;
required .PersistentPayload payload = 3;
required .PersistentPayload payload = 3;
required .PersistentPayload payload = 3;
optional .PersistentPayload payload = 1;
optional .PersistentPayload payload = 1;
optional .PersistentPayload payload = 1;
optional string persistenceId = 1;
optional string persistenceId = 1;
optional string persistenceId = 1;
optional string persistenceId = 3;
optional string persistenceId = 3;
optional string persistenceId = 3;
optional string persistenceId = 1;
optional string persistenceId = 1;
optional string persistenceId = 1;
optional string persistenceId = 3;
optional string persistenceId = 3;
optional string persistenceId = 3;
optional .PersistentMessage persistent = 1;
optional .PersistentMessage persistent = 1;
optional .PersistentMessage persistent = 1;
optional .PersistentMessage persistent = 1;
optional .PersistentMessage persistent = 1;
optional .PersistentMessage persistent = 1;
optional .PersistentMessage persistent = 1;
optional int64 persistentSequenceNr = 3;
optional int64 persistentSequenceNr = 3;
optional int64 persistentSequenceNr = 3;
required uint32 port = 3;
required uint32 port = 3;
required uint32 port = 3;
required uint32 port = 3;
required uint32 port = 3;
required uint32 port = 3;
required int32 port = 4;
required int32 port = 4;
required int32 port = 4;
required uint32 port = 3;
required uint32 port = 3;
required uint32 port = 3;
org.apache.camel.ProducerTemplate
ProducerTemplate.
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 string protocol = 1;
required string protocol = 1;
required string protocol = 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;
optional string protocol = 4;
optional string protocol = 4;
optional string protocol = 4;
required string protocol = 1;
required string protocol = 1;
required string protocol = 1;
optional string protocol = 4;
optional string protocol = 4;
optional string protocol = 4;
optional float rateMBit = 6;
optional float rateMBit = 6;
optional float rateMBit = 6;
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 int32 redeliveries = 6;
optional int32 redeliveries = 6;
optional int32 redeliveries = 6;
ActorRef of the actor replying to the request or
null if no actor matched the request.
ActorRef.
optional string ref = 3;
optional string ref = 3;
optional string ref = 3;
optional string ref = 3;
optional string ref = 3;
optional string ref = 3;
required bool reply = 3;
required bool reply = 3;
required bool reply = 3;
repeated string roles = 2;
repeated string roles = 2;
repeated string roles = 2;
repeated string roles = 2;
repeated string roles = 2;
repeated string roles = 2;
repeated string roles = 2;
repeated string roles = 2;
repeated string roles = 2;
repeated int32 rolesIndexes = 4 [packed = true];
repeated int32 rolesIndexes = 4 [packed = true];
repeated int32 rolesIndexes = 4 [packed = true];
repeated int32 rolesIndexes = 4 [packed = true];
repeated int32 rolesIndexes = 4 [packed = true];
repeated int32 rolesIndexes = 4 [packed = true];
repeated int32 rolesIndexes = 4 [packed = true];
repeated int32 rolesIndexes = 4 [packed = true];
repeated int32 rolesIndexes = 4 [packed = true];
repeated string roles = 2;
repeated string roles = 2;
repeated string roles = 2;
Mapper function that will be used as a route definition handler
for creating custom route to this consumer.
optional bytes routerConfig = 3;
optional bytes routerConfig = 3;
optional bytes routerConfig = 3;
optional bytes scope = 4;
optional bytes scope = 4;
optional bytes scope = 4;
repeated int32 seen = 1;
repeated int32 seen = 1;
repeated int32 seen = 1;
repeated int32 seen = 1;
repeated int32 seen = 1;
repeated int32 seen = 1;
repeated int32 seen = 1;
repeated int32 seen = 1;
repeated int32 seen = 1;
optional string sender = 11;
optional string sender = 11;
optional string sender = 11;
optional .ActorRefData sender = 4;
optional .ActorRefData sender = 4;
optional .ActorRefData sender = 4;
optional .ActorRefData sender = 4;
optional string sender = 11;
optional string sender = 11;
optional string sender = 11;
optional .ActorRefData sender = 4;
optional .ActorRefData sender = 4;
optional .ActorRefData sender = 4;
optional fixed64 seq = 5;
optional fixed64 seq = 5;
optional fixed64 seq = 5;
optional int64 sequenceNr = 2;
optional int64 sequenceNr = 2;
optional int64 sequenceNr = 2;
optional bytes serialized = 4;
optional bytes serialized = 4;
optional bytes serialized = 4;
required bytes serializedGossip = 3;
required bytes serializedGossip = 3;
required bytes serializedGossip = 3;
required int32 serializerId = 2;
required int32 serializerId = 2;
required int32 serializerId = 2;
required int32 serializerId = 1;
required int32 serializerId = 1;
required int32 serializerId = 1;
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 .MemberStatus status = 3;
required .MemberStatus status = 3;
required .MemberStatus status = 3;
required .ReachabilityStatus status = 3;
required .ReachabilityStatus status = 3;
required .ReachabilityStatus status = 3;
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 .SubjectReachability subjectReachability = 2;
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 .SubjectReachability subjectReachability = 2;
repeated .SubjectReachability subjectReachability = 2;
repeated .SubjectReachability subjectReachability = 2;
repeated .SubjectReachability subjectReachability = 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 string system = 2;
required string system = 2;
required string system = 2;
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 string system = 1;
required string system = 1;
required string system = 1;
required string system = 2;
required string system = 2;
required string system = 2;
required string system = 1;
required string system = 1;
required string system = 1;
optional int64 timeout = 3;
optional int64 timeout = 3;
optional int64 timeout = 3;
required int64 timestamp = 2;
required int64 timestamp = 2;
required int64 timestamp = 2;
optional int64 timestamp = 1;
optional int64 timestamp = 1;
required int64 timestamp = 2;
required int64 timestamp = 2;
required int64 timestamp = 2;
optional int64 timestamp = 1;
required int64 timestamp = 2;
required int64 timestamp = 2;
required int64 timestamp = 2;
required .UniqueAddress to = 2;
required .UniqueAddress to = 2;
required .UniqueAddress to = 2;
required .UniqueAddress to = 2;
required .UniqueAddress to = 2;
required .UniqueAddress to = 2;
required .UniqueAddress to = 2;
required string topic = 1;
required string topic = 1;
required string topic = 1;
required string topic = 1;
required string topic = 1;
required string topic = 1;
required .NodeMetrics.NumberType type = 1;
required .NodeMetrics.NumberType type = 1;
required .NodeMetrics.NumberType type = 1;
required .PatternType type = 1;
required .PatternType type = 1;
required .PatternType type = 1;
required uint32 uid = 2;
required uint32 uid = 2;
required uint32 uid = 2;
required fixed64 uid = 2;
required fixed64 uid = 2;
required fixed64 uid = 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 .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 .AtLeastOnceDeliverySnapshot.UnconfirmedDelivery unconfirmedDeliveries = 2;
repeated .AtLeastOnceDeliverySnapshot.UnconfirmedDelivery unconfirmedDeliveries = 2;
repeated .AtLeastOnceDeliverySnapshot.UnconfirmedDelivery unconfirmedDeliveries = 2;
repeated .AtLeastOnceDeliverySnapshot.UnconfirmedDelivery unconfirmedDeliveries = 2;
repeated .AtLeastOnceDeliverySnapshot.UnconfirmedDelivery unconfirmedDeliveries = 2;
required int32 upNumber = 2;
required int32 upNumber = 2;
required int32 upNumber = 2;
required double value = 1;
required double value = 1;
required double value = 1;
optional uint32 value32 = 2;
optional uint32 value32 = 2;
optional uint32 value32 = 2;
optional uint64 value64 = 3;
optional uint64 value64 = 3;
optional uint64 value64 = 3;
required .VectorClock version = 6;
required .VectorClock version = 6;
required .VectorClock version = 6;
required .VectorClock version = 3;
required .VectorClock version = 3;
required .VectorClock version = 3;
required int64 version = 4;
required int64 version = 4;
required int64 version = 4;
required int64 version = 4;
required int64 version = 4;
required int64 version = 4;
required int64 version = 2;
required int64 version = 2;
required int64 version = 2;
required int64 version = 2;
required int64 version = 2;
required int64 version = 2;
required .VectorClock version = 6;
required .VectorClock version = 3;
required .VectorClock version = 6;
required .VectorClock version = 6;
required .VectorClock version = 6;
required .VectorClock version = 3;
required .VectorClock version = 3;
required .VectorClock version = 3;
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 .VectorClock.Version versions = 2;
repeated .Status.Version versions = 1;
repeated .VectorClock.Version versions = 2;
repeated .Status.Version versions = 1;
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 .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 .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 .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;
optional bool wildcardFanOut = 5;
optional bool wildcardFanOut = 5;
optional bool wildcardFanOut = 5;
GossipStatus
initiates a gossip chat between two members.Future that will be completed with success (value true) when
existing messages of the target actor has been processed and the actor has been
terminated.
Future that will be completed with success (value true) when
existing messages of the target actor has been processed and the actor has been
terminated.
Future that will be completed with success (value true) when
existing messages of the target actor has been processed and the actor has been
terminated.
Future that will be completed with success (value true) when
existing messages of the target actor has been processed and the actor has been
terminated.
Future that will be completed with success (value true) when
existing messages of the target actor has been processed and the actor has been
terminated.
RouterConfig for router actor with routee actors that are created external to the
router and the router sends messages to the specified path using actor selection,
without watching for termination.Grouptrue), or it returns false to escalate the
failure, which will lead to this actor re-throwing the exception which
caused the failure.
optional .AcknowledgementInfo ack = 1;
optional .AcknowledgementInfo ack = 1;
optional .AcknowledgementInfo ack = 1;
optional .Address addr = 2;
optional .Address addr = 2;
optional .Address addr = 2;
optional .AddressRequest addr = 5;
optional .AddressRequest addr = 5;
optional .AddressRequest addr = 5;
required .Address address = 1;
required .Address address = 1;
required .Address address = 1;
required .Address address = 1;
required .Address address = 1;
required .Address address = 1;
required .Address address = 2;
required .Address address = 2;
required .Address address = 2;
optional .Address address = 3;
optional .Address address = 3;
optional .Address address = 3;
required int32 addressIndex = 1;
required int32 addressIndex = 1;
required int32 addressIndex = 1;
required int32 addressIndex = 1;
required int32 addressIndex = 1;
required int32 addressIndex = 1;
required int32 addressIndex = 1;
required int32 addressIndex = 1;
required int32 addressIndex = 1;
required int32 addressIndex = 1;
required int32 addressIndex = 1;
required int32 addressIndex = 1;
required bool allButSelf = 2;
required bool allButSelf = 2;
required bool allButSelf = 2;
required double alpha = 2;
required double alpha = 2;
required double alpha = 2;
optional .EnterBarrier barrier = 2;
optional .EnterBarrier barrier = 2;
optional .EnterBarrier barrier = 2;
optional string channel = 5;
optional string channel = 5;
optional string channel = 5;
optional string channelId = 2;
optional string channelId = 2;
optional string channelId = 2;
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 bool confirmable = 8;
optional bool confirmable = 8;
optional bool confirmable = 8;
optional .DeliveredMessage confirmMessage = 9;
optional .DeliveredMessage confirmMessage = 9;
optional .DeliveredMessage confirmMessage = 9;
optional string confirmTarget = 10;
optional string confirmTarget = 10;
optional string confirmTarget = 10;
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 int64 currentDeliveryId = 1;
required int64 currentDeliveryId = 1;
required int64 currentDeliveryId = 1;
optional bool deleted = 4;
optional bool deleted = 4;
optional bool deleted = 4;
required int64 deliveryId = 1;
required int64 deliveryId = 1;
required int64 deliveryId = 1;
optional int64 deliverySequenceNr = 4;
optional int64 deliverySequenceNr = 4;
optional int64 deliverySequenceNr = 4;
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 string destination = 2;
required string destination = 2;
required string destination = 2;
optional string destination = 2;
optional string destination = 2;
optional string destination = 2;
optional .Direction direction = 2;
optional .Direction direction = 2;
optional .Direction direction = 2;
optional string dispatcher = 5;
optional string dispatcher = 5;
optional string dispatcher = 5;
optional string done = 4;
optional string done = 4;
optional string done = 4;
required bytes enclosedMessage = 1;
required bytes enclosedMessage = 1;
required bytes enclosedMessage = 1;
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 .NodeMetrics.EWMA ewma = 3;
optional .NodeMetrics.EWMA ewma = 3;
optional .NodeMetrics.EWMA ewma = 3;
optional int32 exitValue = 7;
optional int32 exitValue = 7;
optional int32 exitValue = 7;
required .FailType failure = 1;
required .FailType failure = 1;
required .FailType failure = 1;
optional .InjectFailure failure = 3;
optional .InjectFailure failure = 3;
optional .InjectFailure failure = 3;
required .UniqueAddress from = 1;
required .UniqueAddress from = 1;
required .UniqueAddress from = 1;
required .UniqueAddress from = 1;
required .UniqueAddress from = 1;
required .UniqueAddress from = 1;
required .Address from = 1;
required .Address from = 1;
required .Address from = 1;
required .UniqueAddress from = 1;
required .UniqueAddress from = 1;
required .UniqueAddress from = 1;
required .MetricsGossip gossip = 2;
required .MetricsGossip gossip = 2;
required .MetricsGossip gossip = 2;
required .Gossip gossip = 2;
required .Gossip gossip = 2;
required .Gossip gossip = 2;
optional .AkkaHandshakeInfo handshakeInfo = 2;
optional .AkkaHandshakeInfo handshakeInfo = 2;
optional .AkkaHandshakeInfo handshakeInfo = 2;
required int32 hashIndex = 1;
required int32 hashIndex = 1;
required int32 hashIndex = 1;
hashCode.hashCode.optional .Hello hello = 1;
optional .Hello hello = 1;
optional .Hello hello = 1;
required string host = 3;
required string host = 3;
required string host = 3;
required string hostname = 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;
required string hostname = 2;
required string hostname = 2;
optional .AkkaControlMessage instruction = 2;
optional .AkkaControlMessage instruction = 2;
optional .AkkaControlMessage instruction = 2;
required string key = 1;
required string key = 1;
required string key = 1;
required bool localAffinity = 2;
required bool localAffinity = 2;
required bool localAffinity = 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 = 4;
optional bytes messageManifest = 4;
optional bytes messageManifest = 4;
optional bytes messageManifest = 3;
optional bytes messageManifest = 3;
optional bytes messageManifest = 3;
required string name = 1;
required string name = 1;
required string name = 1;
required string name = 1;
required string name = 1;
required string name = 1;
required int32 nameIndex = 1;
required int32 nameIndex = 1;
required int32 nameIndex = 1;
required .UniqueAddress node = 1;
required .UniqueAddress node = 1;
required .UniqueAddress node = 1;
required string node = 1;
required string node = 1;
required string node = 1;
required .NodeMetrics.Number number = 2;
required .NodeMetrics.Number number = 2;
required .NodeMetrics.Number number = 2;
required .BarrierOp op = 2;
required .BarrierOp op = 2;
required .BarrierOp op = 2;
required .AddressData origin = 1;
required .AddressData origin = 1;
required .AddressData origin = 1;
required .GossipOverview overview = 5;
required .GossipOverview overview = 5;
required .GossipOverview overview = 5;
required .Address owner = 1;
required .Address owner = 1;
required .Address owner = 1;
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 = 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 .Payload payload = 3;
required .Payload payload = 3;
required .Payload payload = 3;
required .Payload payload = 3;
required .Payload payload = 3;
required .Payload payload = 3;
required .Payload payload = 3;
required .Payload payload = 3;
required .Payload payload = 3;
required .PersistentPayload payload = 3;
required .PersistentPayload payload = 3;
required .PersistentPayload payload = 3;
optional .PersistentPayload payload = 1;
optional .PersistentPayload payload = 1;
optional .PersistentPayload payload = 1;
required bytes payload = 2;
required bytes payload = 2;
required bytes payload = 2;
optional bytes payload = 1;
optional bytes payload = 1;
optional bytes payload = 1;
optional bytes payloadManifest = 3;
optional bytes payloadManifest = 3;
optional bytes payloadManifest = 3;
optional string persistenceId = 1;
optional string persistenceId = 1;
optional string persistenceId = 1;
optional string persistenceId = 3;
optional string persistenceId = 3;
optional string persistenceId = 3;
optional .PersistentMessage persistent = 1;
optional .PersistentMessage persistent = 1;
optional .PersistentMessage persistent = 1;
optional int64 persistentSequenceNr = 3;
optional int64 persistentSequenceNr = 3;
optional int64 persistentSequenceNr = 3;
required uint32 port = 3;
required uint32 port = 3;
required uint32 port = 3;
required uint32 port = 3;
required uint32 port = 3;
required uint32 port = 3;
required int32 port = 4;
required int32 port = 4;
required int32 port = 4;
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;
optional string protocol = 4;
optional string protocol = 4;
optional string protocol = 4;
required string protocol = 1;
required string protocol = 1;
required string protocol = 1;
optional string protocol = 4;
optional string protocol = 4;
optional string protocol = 4;
optional float rateMBit = 6;
optional float rateMBit = 6;
optional float rateMBit = 6;
required .ActorRefData recipient = 1;
required .ActorRefData recipient = 1;
required .ActorRefData recipient = 1;
optional int32 redeliveries = 6;
optional int32 redeliveries = 6;
optional int32 redeliveries = 6;
optional string ref = 3;
optional string ref = 3;
optional string ref = 3;
required bool reply = 3;
required bool reply = 3;
required bool reply = 3;
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 string sender = 11;
optional string sender = 11;
optional string sender = 11;
optional .ActorRefData sender = 4;
optional .ActorRefData sender = 4;
optional .ActorRefData sender = 4;
optional fixed64 seq = 5;
optional fixed64 seq = 5;
optional fixed64 seq = 5;
optional int64 sequenceNr = 2;
optional int64 sequenceNr = 2;
optional int64 sequenceNr = 2;
AckedSendBuffer or AckedReceiveBuffer has
to implement this interface to provide the sequence needed by the buffers.optional bytes serialized = 4;
optional bytes serialized = 4;
optional bytes serialized = 4;
required bytes serializedGossip = 3;
required bytes serializedGossip = 3;
required bytes serializedGossip = 3;
required int32 serializerId = 2;
required int32 serializerId = 2;
required int32 serializerId = 2;
required int32 serializerId = 1;
required int32 serializerId = 1;
required int32 serializerId = 1;
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 .MemberStatus status = 3;
required .MemberStatus status = 3;
required .MemberStatus status = 3;
required .ReachabilityStatus status = 3;
required .ReachabilityStatus status = 3;
required .ReachabilityStatus status = 3;
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 string system = 2;
required string system = 2;
required string system = 2;
required string system = 1;
required string system = 1;
required string system = 1;
optional int64 timeout = 3;
optional int64 timeout = 3;
optional int64 timeout = 3;
required int64 timestamp = 2;
required int64 timestamp = 2;
required int64 timestamp = 2;
optional int64 timestamp = 1;
optional int64 timestamp = 1;
required int64 timestamp = 2;
required int64 timestamp = 2;
required int64 timestamp = 2;
optional int64 timestamp = 1;
required int64 timestamp = 2;
required int64 timestamp = 2;
required int64 timestamp = 2;
required .UniqueAddress to = 2;
required .UniqueAddress to = 2;
required .UniqueAddress to = 2;
required string topic = 1;
required string topic = 1;
required string topic = 1;
required .NodeMetrics.NumberType type = 1;
required .NodeMetrics.NumberType type = 1;
required .NodeMetrics.NumberType type = 1;
required .PatternType type = 1;
required .PatternType type = 1;
required .PatternType type = 1;
required uint32 uid = 2;
required uint32 uid = 2;
required uint32 uid = 2;
required fixed64 uid = 2;
required fixed64 uid = 2;
required fixed64 uid = 2;
required int32 upNumber = 2;
required int32 upNumber = 2;
required int32 upNumber = 2;
required double value = 1;
required double value = 1;
required double value = 1;
optional uint32 value32 = 2;
optional uint32 value32 = 2;
optional uint32 value32 = 2;
optional uint64 value64 = 3;
optional uint64 value64 = 3;
optional uint64 value64 = 3;
required .VectorClock version = 6;
required .VectorClock version = 6;
required .VectorClock version = 6;
required .VectorClock version = 3;
required .VectorClock version = 3;
required .VectorClock version = 3;
required int64 version = 4;
required int64 version = 4;
required int64 version = 4;
required int64 version = 4;
required int64 version = 4;
required int64 version = 4;
required int64 version = 2;
required int64 version = 2;
required int64 version = 2;
required int64 version = 2;
required int64 version = 2;
required int64 version = 2;
optional bool wildcardFanOut = 5;
optional bool wildcardFanOut = 5;
optional bool wildcardFanOut = 5;
name parameter in a Try.
names.
HEARTBEAT = 3;
requiring methods.HighWatermark option shall set the high water mark for the specified socket.ActorIdentity containing the ActorRef.Identity valueSystem.identityHashCode,
unless that happens to be the same for two non-equals objects, in which
case the supplied “real” comparator is used; the comparator must be
consistent with equals, otherwise it would not be an enhancement over
the identityHashCode.
System.identityHashCode,
unless that happens to be the same for two non-equals objects, in which
case the supplied “real” comparator is used; the comparator must be
consistent with equals, otherwise it would not be an enhancement over
the identityHashCode.
Update request, switches to replayStarted state and triggers
an incremental message replay.
Update request, switches to replayStarted state and triggers
an incremental message replay.
Iterable into an immutable Scala IndexedSeq (by copying it).
Iterable into an immutable Scala IndexedSeq (by copying it).
Iterable into an immutable Scala sequence (by copying it).
Iterable into an immutable Scala sequence (by copying it).
akka.actor.dsl.Inbox!.Inbox!.receive
and akka.actor.dsl.Inbox!.Inbox!.select methods.
Actor
subclass.Inet.SocketOption to set the SO_RCVBUF optionInet.SocketOption to enable or disable SO_REUSEADDRInet.SocketOption to set the SO_SNDBUF option.Inet.SocketOption to set the traffic class or
type-of-service octet in the IP header for packets sent from this
socket.source, if given, applies a filter on the event’s origin
message applies a filter on the event’s message (either with String.startsWith or Regex.findFirstIn().isDefined)
If you want to match all Info events, the most efficient is to use Left("").processing state.
Integer = 3;
ClusterDaemon to create a
OnMemberUpListener.receiver is defined the event will only be sent to that
actor, otherwise it will be sent to all subscribers via the eventStream.null is an invalid message.true iff the connection has been closed in response to an Abort command.
Down
and not Removed.
Down
and not Removed.
true iff the connection has been fully closed in response to a
ConfirmedClose command.
true iff the connection has been closed due to an IO error.
RouterConfig.routingLogicController(akka.routing.RoutingLogic) actor.
true iff the connection has been closed by the peer; in case
keepOpenOnPeerClosed is in effect as per the Tcp.Register command,
this connection’s reading half is now closed.
true, the currently processed message was persisted (is sent from the Journal).
FSM.isStateTimerActive().
FSM.isStateTimerActive().
java.util.logging logger.Logging API available as the log
field, using java.util.logging as the backend.isCheck == true and the latter to isCheck == false for those cases where
this is important to know.true or the
timeout expires, whichever comes first.match function or the idle timeout is met (disabled by
default) or the overall maximum duration is elapsed.min and max.address.
Joining = 0;
persistenceId.
PersistentActor provides,
using the provided Journal (plugin).messageIds.JournalProtocol.DeleteMessages request.JournalProtocol.DeleteMessages request.toSequenceNr
(inclusive).message back to persistent actor, without persisting the message.JournalProtocol.LoopMessage request.JournalProtocol.ReadHighestSequenceNr request.JournalProtocol.ReadHighestSequenceNr request.JournalProtocol.ReplayMessages request.persistentActor.JournalProtocol.ReplayMessages request.JournalProtocol.ReplayMessages request.JournalProtocol.WriteConfirmations request.JournalProtocol.WriteConfirmations request.JournalProtocol.WriteMessages request.JournalProtocol.WriteMessages request.JournalProtocol.WriteMessages request.JournalProtocol.WriteMessages request.ExtendedActorSystem, because
that is the preferred constructor which will be invoked when reflectively instantiating
the JSerializer (also possible with empty constructor).Inet.SocketOption to enable or disable SO_KEEPALIVE
Inet.SocketOption to enable or disable SO_KEEPALIVE
TestTransport.AssociationRegistry to identify associations.
0L if this actor hasn't received a persistent
message yet.
Leaving = 2;
TestTransport.SwitchableLoggedBehavior for the listen() method.
FailureDetector implementation.
FailureDetector implementation.
ActorSystem.eventStream.
SupervisorStrategy.loggingEnabled() is true.
true.
FSM which adds a rolling event log and
debug logging capabilities (analogous to LoggingReceive).Logging’s apply/create method.FSM.Failure is logged at error level and other reason
types are not logged.
Long = 4;
LookupClassification
E is the Event type
S is the Subscriber type
C is the Classifier typeDeploy instance.
ActorSystem with one
top level application supervisor actor.ActorSystem with one
top level application supervisor actor.transformer function.
transformer function.
PFBuilder with a case statement added.
PFBuilder with a case statement added.
PartialFunction that can be built during
runtime from Java.PFBuilder with the first
case statement added.
PFBuilder with the first
case statement added.
UnitPFBuilder with a case statement added.
UnitPFBuilder with a case statement added.
UnitPFBuilder with the first
case statement added.
UnitPFBuilder with the first
case statement added.
PFBuilder with a case statement added.
PFBuilder with the first
case statement added.
UnitPFBuilder with a case statement added.
UnitPFBuilder with the first
case statement added.
FSMStateFunctionBuilder with the first case statement set.
UnitPFBuilder with the first case statement set.
UnitPFBuilder with the first case statement set.
PFBuilder with the first
case statement added.
UnitPFBuilder with a case statement added.
UnitPFBuilder with a case statement added.
UnitPFBuilder with the first
case statement added.
UnitPFBuilder with the first
case statement added.
true) or not
(false).
FSMStateFunctionBuilder with the first case statement set.
FSMStateFunctionBuilder with the first case statement set.
FSMStateFunctionBuilder with the first case statement set.
FSMStateFunctionBuilder with the first case statement set.
FSMStateFunctionBuilder with the first case statement set.
FSMStateFunctionBuilder with the first case statement set.
FSMStateFunctionBuilder with the first case statement set.
FSMStateFunctionBuilder with the first case statement set.
FSMStateFunctionBuilder with the first case statement set.
FSMTransitionHandlerBuilder with the first case statement set.
FSMTransitionHandlerBuilder with the first case statement set.
FSMStopBuilder with the first case statement set.
FSMStopBuilder with the first case statement set.
FSMStopBuilder with the first case statement set.
Slf4jLogger is configured.
DistributedPubSubMediator
NodeMetrics and merges existing from a remote gossip.
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;
optional .EnterBarrier barrier = 2;
optional .DeliveredMessage confirmMessage = 9;
required .DeployData deploy = 2;
required .DeployData deploy = 2;
optional .RemoteEnvelope envelope = 2;
optional .NodeMetrics.EWMA ewma = 3;
optional .InjectFailure failure = 3;
required .MetricsGossip gossip = 2;
required .Gossip gossip = 2;
optional .AkkaHandshakeInfo handshakeInfo = 2;
optional .Hello hello = 1;
optional .AkkaControlMessage instruction = 2;
required .SerializedMessage message = 2;
required .UniqueAddress node = 1;
required .NodeMetrics.Number number = 2;
required .AddressData origin = 1;
required .GossipOverview overview = 5;
required .Address owner = 1;
required .Payload payload = 3;
required .Payload payload = 3;
required .Payload payload = 3;
required .PersistentPayload payload = 3;
optional .PersistentPayload payload = 1;
optional .PersistentMessage persistent = 1;
required .PropsData props = 1;
required .ActorRefData recipient = 1;
optional .ActorRefData sender = 4;
required .ActorRefData supervisor = 4;
required .UniqueAddress to = 2;
required .VectorClock version = 6;
required .VectorClock version = 3;
akka.persistence.AtLeastOnceDeliverySnapshotAtLeastOnceDeliverySnapshotAtLeastOnceDeliverySnapshot.UnconfirmedDeliveryAtLeastOnceDeliverySnapshot.UnconfirmedDeliveryDeliveredMessageDeliveredMessageDeliverMessageDeliverMessagePersistentMessagePersistentMessagePersistentMessageBatchPersistentMessageBatchPersistentPayloadPersistentPayloadPersistentBatch, PersistentRepr and Deliver messages.MulticastHopsMulticastLooptestconductor, or helper methods that use testconductor,
from the constructor of your test class.selfAddress.
Props to build a ZeroMQ Dealer socket actor.
Props to build a ZeroMQ Publisher socket actor.
Props to build a ZeroMQ Pull socket actor.
Props to build a ZeroMQ Push socket actor.
Props to build a ZeroMQ Rep socket actor.
Props to build a ZeroMQ Req socket actor.
Props to build a ZeroMQ Router socket actor.
Props to build the ZeroMQ socket actor.
Props to build a ZeroMQ Subscriber socket actor.
Tcp.WriteCommand can optionally request a positive acknowledgment to be sent
to the commanding actor.
Tcp.NoAck instance which is used when no acknowledgment information is
explicitly provided.
Tcp.WriteCommand can optionally request a positive acknowledgment to be sent
to the commanding actor.
Tcp.NoAck instance which is used when no acknowledgment information is
explicitly provided.
UdpConnected.Send can optionally request a positive acknowledgment to be sent
to the commanding actor.
UdpConnected.NoAck instance which is used when no acknowledgment information is
explicitly provided.
UdpConnected.Send can optionally request a positive acknowledgment to be sent
to the commanding actor.
UdpConnected.NoAck instance which is used when no acknowledgment information is
explicitly provided.
Udp.Send can optionally request a positive acknowledgment to be sent
to the commanding actor.
Udp.NoAck instance which is used when no acknowledgment information is
explicitly provided.
Udp.Send can optionally request a positive acknowledgment to be sent
to the commanding actor.
Udp.NoAck instance which is used when no acknowledgment information is
explicitly provided.
NodeMetrics for a node if exists.
Option factory that creates None
Option factory that creates None
stop().
Routee that doesn't send the message to any routee.Routee that doesn't send the message to any routee.ActorRef.tell(java.lang.Object, akka.actor.ActorRef) if there is not actor to
reply to (e.g.
ActorRef.tell(java.lang.Object, akka.actor.ActorRef) if there is not actor to
reply to (e.g.
System.nanoTime) as Duration.
whenUnhandled and onTermination handlers.
whenUnhandled and onTermination handlers.
id.
Directive (Resume, Restart, Stop) specified in the Decider
to the child actor that failed, as opposed to AllForOneStrategy that applies
it to all children.RecoveryFinished message.
RecoveryFailure message.
idle state and schedules the next update if autoUpdate returns true.
idle state and schedules the next update if autoUpdate returns true.
endpointUri.
getEndpointUri.
Inet.SocketOption to enable or disable OOBINLINE (receipt
of TCP urgent data) By default, this option is disabled and TCP urgent
data is silently discarded.
Inet.SocketOption to enable or disable OOBINLINE (receipt
of TCP urgent data) By default, this option is disabled and TCP urgent
data is silently discarded.
Option factory that creates None if
v is null, Some(v) otherwise.
Option factory that creates None if
v is null, Some(v) otherwise.
Some[A] represents existing values of type
A.Member ordering type class, sorts members by host and port.
Member ordering type class, sorts members by host and port.
PARENT = 0;
event.
events in specified order.
event.
events in specified order.
event.
events in specified order.
event.
events in specified order.
Processor if a journal fails to write a Persistent message.Processor to atomically write the contained Persistent messages to the
journal.PersistentChannel implements the same functionality as a Channel but additionally persists
Deliver requests before they are served.PersistentChannel configuration object.PersistentActor.PartialFunction.PinnedDispatcher.Future to send
the result to the given ActorRef or ActorSelection.
Future to send
the result to the given ActorRef or ActorSelection.
pipeTo method on Future:
TestConductorExt extension.ClientFSM.RouterConfig for router actor that creates routees as child actors and removes
them from the router if they terminate.PoolpreStart().
preStart().
preStart().
others to this stash.
Write or WriteFile to form
a CompoundWrite.
postStop().'''
postStop().'''
postStop().'''
preRestart and then super.preRestart().
autoUpdateReplayMax
messages (following that snapshot).
autoUpdateReplayMax
messages (following that snapshot).
router is initalized but before super.start() to
be able to do extra initialization in subclass.
CamelExchangeAdapter
CamelExchangeAdapter.
Persistent.msg to the endpoint specified by endpointUri.
pattern with the endpoint specified by
endpointUri.
ClusterRemoteWatcher Props.
ClusterRemoteWatcher Props.
ClusterClient Props.
ClusterClient Props.
ClusterClient Props.
ClusterClient Props.
ClusterReceptionist Props.
ClusterReceptionist Props.
ClusterReceptionist Props
with default values.
ClusterReceptionist Props.
ClusterReceptionist Props.
ClusterReceptionist Props
with default values.
ClusterSingletonManager Props.
ClusterSingletonManager Props.
ClusterSingletonManager Props.
ClusterSingletonManager Props.
ClusterSingletonProxy Props.
ClusterSingletonProxy Props.
ClusterSingletonProxy Props.
ClusterSingletonProxy Props.
DistributedPubSubMediator Props.
DistributedPubSubMediator Props.
DistributedPubSubMediator Props.
DistributedPubSubMediator Props.
Props of the ShardCoordinator actor.
Props of the ShardCoordinator actor.
Props of the ShardCoordinator actor.
Props of the ShardCoordinator actor.
Props of the ShardRegion actor.
Props of the ShardRegion actor.
Props of the ShardRegion actor.
Props of the ShardRegion actor.
Props of the ShardRegion actor.
Props of the ShardRegion actor.
Channel with a
generated id and default ChannelSettings.
Channel with a
generated id and specified channelSettings.
Channel with the
specified id and default ChannelSettings.
Channel with the
specified id and specified channelSettings.
Channel with a
generated id and default ChannelSettings.
Channel with a
generated id and specified channelSettings.
Channel with the
specified id and default ChannelSettings.
Channel with the
specified id and specified channelSettings.
PersistentChannel with a
generated id and default PersistentChannelSettings.
PersistentChannel with a
generated id and specified channelSettings.
PersistentChannel with the
specified id and default PersistentChannelSettings.
PersistentChannel with the
specified id and specified channelSettings.
PersistentChannel with a
generated id and default PersistentChannelSettings.
PersistentChannel with a
generated id and specified channelSettings.
PersistentChannel with the
specified id and default PersistentChannelSettings.
PersistentChannel with the
specified id and specified channelSettings.
RemoteWatcher Props.
RemoteWatcher Props.
Props for a group router based on the settings defined by
this instance.
Props for a group router based on the settings defined by
this instance.
Props for a pool router based on the settings defined by
this instance and the supplied Props for the routees created by the
router.
com.google.protobuf.MessagesProps of the ShardRegion actor
when using it in proxy only mode.
Props of the ShardRegion actor
when using it in proxy only mode.
Props of the ShardRegion actor
when using it in proxy only mode.
Props of the ShardRegion actor
when using it in proxy only mode.
ClusterEvent.ClusterDomainEvent
or ClusterEvent.CurrentClusterState.
n least significant bytes of the given Long to this builder.
rampupRate.
Reachable = 0;
AssociationHandle.HandleEventListener
to register a listener responsible for handling incoming payload.
become to change this.
receiver actor.
Receive = 2;
Inet.SocketOption to set the SO_RCVBUF option
Inet.SocketOption to set the SO_RCVBUF option
ReceiveBufferSize option shall set the underlying kernel receive buffer size for the socket to
the specified size in bytes.ReceiveBufferSizeActor.receive().ReceiveHighWatermark option shall set the high water mark for inbound messages on the specified socket.receiveN(n, remaining()), but correctly treating the
timeFactor.
receiveN(n, remaining) but correctly taking into account
Duration.timeFactor.
akka.cluster.MemberStatus.Up.
ReconnectIVLMax option shall set the maximum reconnection interval for the specified socket.Processor when the journal replay has been finished.Processor if a journal fails to replay messages or fetch that processor's
highest sequence number.true if this processor has successfully finished recovery.
RecoveryIntervaltrue if this processor is currently recovering.
ReliableDelivery.DynamicAccess implementation used by ExtendedActorSystem
unless overridden.register
Tcp.Connected message.
register(handler, false, false).
Tcp.Connected message.
register(handler, false, false).
MessageDispatcherConfigurator that will be
used by Dispatchers.lookup(java.lang.String) and Dispatchers.hasDispatcher(java.lang.String) instead of looking
up the configurator from the system configuration.
Up.
Up.
Deliver requests to their destinations.ProxyTerminated is sent to transition subscribers during postStop.TargetChanged is sent to transition subscribers when the initial connection is made
the target and when the target ActorRef has changed (for example, the target system
crashed and has been restarted).Within block or missing that it returns the properly dilated
default for this case from settings (key
"akka.test.single-expect-default").
within
block or missing that it returns the properly dilated default for this
case from settings (key "akka.test.single-expect-default").
Within block or missing that it returns the given duration.
within
block or missing that it returns the given duration.
ActorRefProvider interface is supported.RouterConfig implementation for remote deployment on defined
target nodes.RemoteTransportException without stack trace.akka.cluster.MemberStatus.Up
repeated .UniqueAddress allAddresses = 1;
repeated .Address allAddresses = 1;
repeated .PersistentMessage batch = 1;
repeated .Delta.Bucket buckets = 1;
repeated .Delta.Entry content = 3;
Removed = 5;
repeated .Member members = 4;
repeated .NodeMetrics.Metric metrics = 3;
repeated .NodeMetrics nodeMetrics = 3;
repeated .ObserverReachability observerReachability = 2;
repeated .Selection pattern = 3;
ActorRefRoutee for the specified
ActorRef.
ActorSelectionRoutee for the specified
ActorSelection.
Router.
repeated .SubjectReachability subjectReachability = 2;
repeated .AtLeastOnceDeliverySnapshot.UnconfirmedDelivery unconfirmedDeliveries = 2;
repeated .VectorClock.Version versions = 2;
repeated .Status.Version versions = 1;
Deliver requests from the journal and processes them.Deliver requests to the journal.value.
PersistentChannel, forcing it to redeliver all unconfirmed persistent
messages.PersistentChannel, forcing it to redeliver all unconfirmed persistent
messages.PersistentChannel child actor to re-initiate delivery.Resizer
to use.
Pool routers with dynamically resizable number of routees are implemented by providing a Resizer
implementation in the Pool configuration.ActorRef matching this selection.
ActorRef matching this selection.
suspend is called,
if it isn't currently suspended, it is a no-op.
Tcp.SuspendReading
command in order to resume reading from the socket.
Tcp.SuspendReading
command in order to resume reading from the socket.
UdpConnected.SuspendReading command.
UdpConnected.SuspendReading command.
Udp.SuspendReading command.
Udp.SuspendReading command.
useResumeWriting is in effect as was indicated in the Tcp.Register message
then this command needs to be sent to the connection actor in order to re-enable
writing after a Tcp.CommandFailed event.
useResumeWriting is in effect as was indicated in the Tcp.Register message
then this command needs to be sent to the connection actor in order to re-enable
writing after a Tcp.CommandFailed event.
Inet.SocketOption to enable or disable SO_REUSEADDR
Inet.SocketOption to enable or disable SO_REUSEADDR
Routee selected by the RoutingLogic.
Router.Router.route(java.lang.Object, akka.actor.ActorRef) method the
RoutingLogic decides to which Routee to send the message.Deploy instance.
endpointUri.
Router to select
destination routed messages.roleMap).
that is tracking the same metric as this.
that address is the same as this
snapshot of this snapshotter's state.
PersistentActor after failed saving of a snapshot.PersistentActor after successful saving of a snapshot.ScanningClassification
E is the Event type
S is the Subscriber type
C is the Classifier typeDeploy serves two purposes: as a marker for
pattern matching the “scope” (i.e.receiver actor.
SnapshotSelectionCriteria.uid of this cluster member.
Udp.SimpleSender query to the UdpExt.manager() as well as by
the listener actors which are created in response to Udp.Bind.
send(payload, target, noAck()).
Udp.SimpleSender query to the UdpExt.manager() as well as by
the listener actors which are created in response to Udp.Bind.
send(payload, target, noAck()).
Send = 1;
Inet.SocketOption to set the SO_SNDBUF option.
Inet.SocketOption to set the SO_SNDBUF option.
SendBufferSize option shall set the underlying kernel transmit buffer size for the socket to
the specified size in bytes.SendBufferSizeSendHighWatermark option shall set the high water mark for outbound messages on the specified socket.Seq of Cause-Directive pairs to a Decider.
Seq of Throwables to a Decider.
Seq of Throwables to a Decider.
Futures$.traverse(java.lang.Iterable, akka.japi.Function>, scala.concurrent.ExecutionContext) .
Futures.traverse(java.lang.Iterable, akka.japi.Function>, scala.concurrent.ExecutionContext) .
ActorRef to Akka's
protobuf representation.
ActorRef to Akka's
protobuf representation.
Serialized = 0;
ExecutionContext allows to wrap an underlying ExecutionContext and provide guaranteed serial execution
of tasks submitted to it.DynamicAccess.
optional .AcknowledgementInfo ack = 1;
optional .AcknowledgementInfo ack = 1;
optional .Address addr = 2;
optional .Address addr = 2;
optional .AddressRequest addr = 5;
optional .AddressRequest addr = 5;
required .Address address = 1;
required .Address address = 1;
required .Address address = 1;
required .Address address = 1;
required .Address address = 2;
required .Address address = 2;
optional .Address address = 3;
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 .UniqueAddress allAddresses = 1;
repeated .Address 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;
optional .EnterBarrier barrier = 2;
repeated .PersistentMessage batch = 1;
repeated .PersistentMessage batch = 1;
repeated .Delta.Bucket buckets = 1;
repeated .Delta.Bucket buckets = 1;
optional string channel = 5;
optional string channel = 5;
optional string channelId = 2;
optional string channelId = 2;
repeated string classes = 5;
required string clazz = 3;
required string clazz = 3;
required .CommandType commandType = 1;
optional bytes config = 2;
optional bool confirmable = 8;
optional .DeliveredMessage confirmMessage = 9;
optional .DeliveredMessage confirmMessage = 9;
repeated string confirms = 7;
optional string confirmTarget = 10;
optional string confirmTarget = 10;
repeated .Delta.Entry content = 3;
repeated .Delta.Entry content = 3;
optional string cookie = 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;
AtLeastOnceDelivery.getDeliverySnapshot() was saved it will be received during recovery
in a SnapshotOffer message and should be set with this method.
required .DeployData deploy = 2;
required .DeployData deploy = 2;
required .DeployData deploy = 2;
required .DeployData deploy = 2;
required string destination = 2;
optional string destination = 2;
required string destination = 2;
optional string destination = 2;
optional .Direction direction = 2;
optional string dispatcher = 5;
optional string dispatcher = 5;
optional string done = 4;
optional string done = 4;
required bytes enclosedMessage = 1;
required bytes enclosedMessage = 1;
optional .RemoteEnvelope envelope = 2;
optional .RemoteEnvelope envelope = 2;
optional .NodeMetrics.EWMA ewma = 3;
optional .NodeMetrics.EWMA ewma = 3;
optional int32 exitValue = 7;
required .FailType failure = 1;
optional .InjectFailure failure = 3;
optional .InjectFailure failure = 3;
required .UniqueAddress from = 1;
required .UniqueAddress from = 1;
required .UniqueAddress from = 1;
required .UniqueAddress from = 1;
required .Address from = 1;
required .Address from = 1;
required .UniqueAddress from = 1;
required .UniqueAddress from = 1;
required .MetricsGossip gossip = 2;
required .MetricsGossip gossip = 2;
required .Gossip gossip = 2;
required .Gossip gossip = 2;
optional .AkkaHandshakeInfo handshakeInfo = 2;
optional .AkkaHandshakeInfo handshakeInfo = 2;
required int32 hashIndex = 1;
optional .Hello hello = 1;
optional .Hello hello = 1;
required string host = 3;
required string host = 3;
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;
required string key = 1;
required string key = 1;
required bool localAffinity = 2;
optional string matcher = 2;
optional string matcher = 2;
repeated .Member members = 4;
repeated .Member members = 4;
required .SerializedMessage message = 2;
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 .NodeMetrics.Metric metrics = 3;
repeated fixed64 nacks = 2;
required string name = 1;
required string name = 1;
required string name = 1;
required string name = 1;
required int32 nameIndex = 1;
required .UniqueAddress node = 1;
required .UniqueAddress node = 1;
required string node = 1;
required string node = 1;
repeated .NodeMetrics nodeMetrics = 3;
repeated .NodeMetrics nodeMetrics = 3;
required .NodeMetrics.Number number = 2;
required .NodeMetrics.Number number = 2;
repeated .ObserverReachability observerReachability = 2;
repeated .ObserverReachability observerReachability = 2;
required .BarrierOp op = 2;
required .AddressData origin = 1;
required .AddressData origin = 1;
required .GossipOverview overview = 5;
required .GossipOverview overview = 5;
required .Address owner = 1;
required .Address owner = 1;
required string path = 1;
required string path = 1;
required string path = 1;
required string path = 3;
required string path = 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;
repeated .Selection pattern = 3;
required .Payload payload = 3;
required .Payload payload = 3;
required .Payload payload = 3;
required .Payload payload = 3;
required .Payload payload = 3;
required .Payload payload = 3;
required .PersistentPayload payload = 3;
required .PersistentPayload payload = 3;
optional .PersistentPayload payload = 1;
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 string persistenceId = 1;
optional string persistenceId = 3;
optional .PersistentMessage persistent = 1;
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;
required .PropsData props = 1;
optional string protocol = 4;
optional string protocol = 4;
required string protocol = 1;
optional string protocol = 4;
optional string protocol = 4;
optional string protocol = 4;
required string protocol = 1;
optional string protocol = 4;
optional float rateMBit = 6;
ReceiveTimeout message is triggered.
required .ActorRefData recipient = 1;
required .ActorRefData recipient = 1;
optional int32 redeliveries = 6;
optional string ref = 3;
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 .ActorRefData sender = 4;
optional string sender = 11;
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;
store for the given actor system.
store for the given actor system.
repeated .SubjectReachability subjectReachability = 2;
repeated .SubjectReachability subjectReachability = 2;
required .ActorRefData supervisor = 4;
required .ActorRefData supervisor = 4;
required string system = 1;
required string system = 1;
required string system = 2;
required string system = 1;
required string system = 1;
required string system = 1;
required string system = 2;
required string system = 1;
optional int64 timeout = 3;
FSM.setTimer(java.lang.String, java.lang.Object, scala.concurrent.duration.FiniteDuration, boolean).
required int64 timestamp = 2;
optional int64 timestamp = 1;
required int64 timestamp = 2;
required int64 timestamp = 2;
required .UniqueAddress to = 2;
required .UniqueAddress to = 2;
required string topic = 1;
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;
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 = 6;
required .VectorClock version = 3;
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 .VectorClock.Version versions = 2;
repeated .Status.Version versions = 1;
repeated .Status.Version versions = 1;
optional bool wildcardFanOut = 5;
Routee that sends each message to all routees.ShardCoordinator
should extend this abstract class and implement the two methods.ShardCoordinator initiates rebalancing process by sending this message
to all registered ShardRegion actors (including proxy only).ShardCoordinator.Internal$.BeginHandOffShardRegion requests the location of a shard by sending this message
to the ShardCoordinator.ShardRegion actors have acknoledged the ShardCoordinator.Internal$.BeginHandOff the
ShardCoordinator sends this message to the ShardRegion responsible for the
shard.- ShardCoordinator.Internal$.HandOff(String) -
Constructor for class akka.contrib.pattern.ShardCoordinator.Internal$.HandOff
-
- ShardCoordinator.Internal$.Register - Class in akka.contrib.pattern
ShardRegion registers to ShardCoordinator, until it receives ShardCoordinator.Internal$.RegisterAck. - ShardCoordinator.Internal$.Register(ActorRef) -
Constructor for class akka.contrib.pattern.ShardCoordinator.Internal$.Register
-
- ShardCoordinator.Internal$.RegisterAck - Class in akka.contrib.pattern
- Acknowledgement from
ShardCoordinator that ShardCoordinator.Internal$.Register or ShardCoordinator.Internal$.RegisterProxy was sucessful. - ShardCoordinator.Internal$.RegisterAck(ActorRef) -
Constructor for class akka.contrib.pattern.ShardCoordinator.Internal$.RegisterAck
-
- ShardCoordinator.Internal$.RegisterProxy - Class in akka.contrib.pattern
ShardRegion in proxy only mode registers to ShardCoordinator, until it receives ShardCoordinator.Internal$.RegisterAck. - ShardCoordinator.Internal$.RegisterProxy(ActorRef) -
Constructor for class akka.contrib.pattern.ShardCoordinator.Internal$.RegisterProxy
-
- ShardCoordinator.Internal$.ShardHome - Class in akka.contrib.pattern
ShardCoordinator replies with this message for ShardCoordinator.Internal$.GetShardHome requests.- ShardCoordinator.Internal$.ShardHome(String, ActorRef) -
Constructor for class akka.contrib.pattern.ShardCoordinator.Internal$.ShardHome
-
- ShardCoordinator.Internal$.ShardHomeAllocated - Class in akka.contrib.pattern
-
- ShardCoordinator.Internal$.ShardHomeAllocated(String, ActorRef) -
Constructor for class akka.contrib.pattern.ShardCoordinator.Internal$.ShardHomeAllocated
-
- ShardCoordinator.Internal$.ShardHomeDeallocated - Class in akka.contrib.pattern
-
- ShardCoordinator.Internal$.ShardHomeDeallocated(String) -
Constructor for class akka.contrib.pattern.ShardCoordinator.Internal$.ShardHomeDeallocated
-
- ShardCoordinator.Internal$.ShardRegionProxyRegistered - Class in akka.contrib.pattern
-
- ShardCoordinator.Internal$.ShardRegionProxyRegistered(ActorRef) -
Constructor for class akka.contrib.pattern.ShardCoordinator.Internal$.ShardRegionProxyRegistered
-
- ShardCoordinator.Internal$.ShardRegionProxyTerminated - Class in akka.contrib.pattern
-
- ShardCoordinator.Internal$.ShardRegionProxyTerminated(ActorRef) -
Constructor for class akka.contrib.pattern.ShardCoordinator.Internal$.ShardRegionProxyTerminated
-
- ShardCoordinator.Internal$.ShardRegionRegistered - Class in akka.contrib.pattern
-
- ShardCoordinator.Internal$.ShardRegionRegistered(ActorRef) -
Constructor for class akka.contrib.pattern.ShardCoordinator.Internal$.ShardRegionRegistered
-
- ShardCoordinator.Internal$.ShardRegionTerminated - Class in akka.contrib.pattern
-
- ShardCoordinator.Internal$.ShardRegionTerminated(ActorRef) -
Constructor for class akka.contrib.pattern.ShardCoordinator.Internal$.ShardRegionTerminated
-
- ShardCoordinator.Internal$.ShardStopped - Class in akka.contrib.pattern
- Reply to
ShardCoordinator.Internal$.BeginHandOff when all entries in the shard have been terminated. - ShardCoordinator.Internal$.ShardStopped(String) -
Constructor for class akka.contrib.pattern.ShardCoordinator.Internal$.ShardStopped
-
- ShardCoordinator.Internal$.State - Class in akka.contrib.pattern
-
- ShardCoordinator.Internal$.State() -
Constructor for class akka.contrib.pattern.ShardCoordinator.Internal$.State
-
- ShardCoordinator.LeastShardAllocationStrategy - Class in akka.contrib.pattern
- The default implementation of
ShardCoordinator.LeastShardAllocationStrategy
allocates new shards to the ShardRegion with least number of previously allocated shards. - ShardCoordinator.LeastShardAllocationStrategy(int, int) -
Constructor for class akka.contrib.pattern.ShardCoordinator.LeastShardAllocationStrategy
-
- ShardCoordinator.RebalanceWorker - Class in akka.contrib.pattern
- INTERNAL API.
- ShardCoordinator.RebalanceWorker(String, ActorRef, FiniteDuration, Set<ActorRef>) -
Constructor for class akka.contrib.pattern.ShardCoordinator.RebalanceWorker
-
- ShardCoordinator.ShardAllocationStrategy - Interface in akka.contrib.pattern
- Interface of the pluggable shard allocation and rebalancing logic used by the
ShardCoordinator. - ShardCoordinatorSupervisor - Class in akka.contrib.pattern
-
- ShardCoordinatorSupervisor(FiniteDuration, Props) -
Constructor for class akka.contrib.pattern.ShardCoordinatorSupervisor
-
- ShardCoordinatorSupervisor$ - Class in akka.contrib.pattern
-
- ShardCoordinatorSupervisor$() -
Constructor for class akka.contrib.pattern.ShardCoordinatorSupervisor$
-
- shardId(Object) -
Method in interface akka.contrib.pattern.ShardRegion.MessageExtractor
- Extract the entry id from an incoming
message.
- sharding() -
Method in class akka.contrib.pattern.ClusterShardingGuardian
-
- shardRegion(String) -
Method in class akka.contrib.pattern.ClusterSharding
- Retrieve the actor reference of the
ShardRegion actor responsible for the named entry type.
- shardRegion() -
Method in class akka.contrib.pattern.ClusterShardingGuardian.Started
-
- shardRegion() -
Method in class akka.contrib.pattern.ShardCoordinator.Internal$.Register
-
- ShardRegion - Class in akka.contrib.pattern
- This actor creates children entry actors on demand for the shards that it is told to be
responsible for.
- ShardRegion(Option<Props>, Option<String>, String, FiniteDuration, int, PartialFunction<Object, Tuple2<String, Object>>, Function1<Object, String>) -
Constructor for class akka.contrib.pattern.ShardRegion
-
- ShardRegion$ - Class in akka.contrib.pattern
-
- ShardRegion$() -
Constructor for class akka.contrib.pattern.ShardRegion$
-
- ShardRegion.HandOffStopper - Class in akka.contrib.pattern
- INTERNAL API.
- ShardRegion.HandOffStopper(String, ActorRef, Set<ActorRef>) -
Constructor for class akka.contrib.pattern.ShardRegion.HandOffStopper
-
- ShardRegion.MessageExtractor - Interface in akka.contrib.pattern
- Java API: Interface of functions to extract entry id,
shard id, and the message to send to the entry from an
incoming message.
- ShardRegion.Passivate - Class in akka.contrib.pattern
- If the state of the entries are persistent you may stop entries that are not used to
reduce memory consumption.
- ShardRegion.Passivate(Object) -
Constructor for class akka.contrib.pattern.ShardRegion.Passivate
-
- ShardRegion.Passivate$ - Class in akka.contrib.pattern
-
- ShardRegion.Passivate$() -
Constructor for class akka.contrib.pattern.ShardRegion.Passivate$
-
- ShardRegion.ShardRegionCommand - Interface in akka.contrib.pattern
-
- shardRegionProxy() -
Method in class akka.contrib.pattern.ShardCoordinator.Internal$.RegisterProxy
-
- shardResolver() -
Method in class akka.contrib.pattern.ClusterShardingGuardian.Start
-
- SharedLeveldbJournal - Class in akka.persistence.journal.leveldb
- INTERNAL API.
- SharedLeveldbJournal() -
Constructor for class akka.persistence.journal.leveldb.SharedLeveldbJournal
-
- SharedLeveldbJournal$ - Class in akka.persistence.journal.leveldb
-
- SharedLeveldbJournal$() -
Constructor for class akka.persistence.journal.leveldb.SharedLeveldbJournal$
-
- SharedLeveldbStore - Class in akka.persistence.journal.leveldb
- A LevelDB store that can be shared by multiple actor systems.
- SharedLeveldbStore() -
Constructor for class akka.persistence.journal.leveldb.SharedLeveldbStore
-
- shouldDropInbound(Address, Object, String) -
Method in class akka.remote.transport.FailureInjectorTransportAdapter
-
- shouldDropOutbound(Address, Object, String) -
Method in class akka.remote.transport.FailureInjectorTransportAdapter
-
- shouldNotProcessMask() -
Method in class akka.dispatch.Mailbox$
-
- shouldNotProcessMask() -
Static method in class akka.dispatch.Mailbox
-
- shouldProcessMessage() -
Method in class akka.dispatch.Mailbox
-
- shouldScheduleMask() -
Method in class akka.dispatch.Mailbox$
-
- shouldScheduleMask() -
Static method in class akka.dispatch.Mailbox
-
- Shutdown() -
Method in class akka.actor.AbstractFSM
- Reason given when someone was calling
system.stop(fsm) from outside;
also applies to Stop supervision directive.
- shutdown() -
Method in class akka.actor.ActorSystem
- Stop this actor system.
- shutdown() -
Method in class akka.actor.ActorSystemImpl
-
- shutdown() -
Method in class akka.actor.mailbox.filebased.filequeue.QueueCollection
- Shutdown this queue collection.
- shutdown() -
Method in class akka.camel.internal.DefaultCamel
- Stops camel and underlying camel context and template.
- shutdown() -
Method in class akka.cluster.Cluster
- INTERNAL API.
- shutdown() -
Method in class akka.cluster.ClusterCoreDaemon
- This method is called when a member sees itself as Exiting or Down.
- shutdown() -
Method in class akka.dispatch.Dispatcher
- INTERNAL API
- shutdown() -
Method in interface akka.dispatch.ExecutorServiceDelegate
-
- shutdown() -
Method in class akka.dispatch.MessageDispatcher
- Called one time every time an actor is detached from this dispatcher and this dispatcher has no actors left attached
Must be idempotent
- shutdown() -
Method in interface akka.kernel.Bootable
- Callback run on microkernel shutdown.
- shutdown() -
Method in class akka.remote.RemoteTransport
- Shuts down the remoting
- shutdown() -
Method in class akka.remote.Remoting
-
- shutdown(RoleName) -
Method in interface akka.remote.testconductor.Conductor
- Tell the actor system at the remote node to shut itself down.
- shutdown(RoleName, boolean) -
Method in interface akka.remote.testconductor.Conductor
- Tell the actor system at the remote node to shut itself down without
awaiting termination of remote-deployed children.
- shutdown(org.jboss.netty.channel.Channel) -
Method in class akka.remote.testconductor.RemoteConnection$
-
- shutdown(org.jboss.netty.channel.Channel) -
Static method in class akka.remote.testconductor.RemoteConnection
-
- shutdown() -
Method in class akka.remote.transport.AbstractTransportAdapter
-
- shutdown() -
Method in class akka.remote.transport.ActorTransportAdapter
-
- shutdown() -
Method in class akka.remote.transport.netty.NettyTransport
-
- shutdown() -
Method in class akka.remote.transport.TestTransport
-
- shutdown() -
Method in interface akka.remote.transport.Transport
- Shuts down the transport layer and releases all the corresponding resources.
- shutdown() -
Method in class akka.testkit.CallingThreadDispatcher
-
- shutdown(ActorSystem, Duration, Boolean) -
Method in class akka.testkit.JavaTestKit
- Shut down an actor system and wait for termination.
- shutdown(ActorSystem) -
Method in class akka.testkit.JavaTestKit
-
- shutdown(ActorSystem, Duration) -
Method in class akka.testkit.JavaTestKit
-
- shutdown(ActorSystem, Boolean) -
Method in class akka.testkit.JavaTestKit
-
- shutdown(ActorSystem, Duration, boolean) -
Method in interface akka.testkit.TestKitBase
- Shut down an actor system and wait for termination.
- Shutdown_VALUE -
Static variable in enum akka.remote.testconductor.TestConductorProtocol.FailType
Shutdown = 5;
- ShutdownAbrupt_VALUE -
Static variable in enum akka.remote.testconductor.TestConductorProtocol.FailType
ShutdownAbrupt = 6;
- shutdownActorSystem(ActorSystem, Duration, Boolean) -
Static method in class akka.testkit.JavaTestKit
- Shut down an actor system and wait for termination.
- shutdownActorSystem(ActorSystem) -
Static method in class akka.testkit.JavaTestKit
-
- shutdownActorSystem(ActorSystem, Duration) -
Method in class akka.testkit.JavaTestKit
-
- shutdownActorSystem(ActorSystem, Boolean) -
Method in class akka.testkit.JavaTestKit
-
- shutdownActorSystem(ActorSystem, Duration, boolean) -
Method in class akka.testkit.TestKit$
- Shut down an actor system and wait for termination.
- shutdownActorSystem(ActorSystem, Duration, boolean) -
Static method in class akka.testkit.TestKit
- Shut down an actor system and wait for termination.
- ShutDownAssociation - Exception in akka.remote
- INTERNAL API
- ShutDownAssociation(Address, Address, Throwable) -
Constructor for exception akka.remote.ShutDownAssociation
-
- ShutDownAssociation$ - Class in akka.remote
-
- ShutDownAssociation$() -
Constructor for class akka.remote.ShutDownAssociation$
-
- shutdownBehavior() -
Method in class akka.remote.transport.TestTransport
- The
TestTransport.SwitchableLoggedBehavior for the shutdown() method.
- shutdownNow() -
Method in interface akka.dispatch.ExecutorServiceDelegate
-
- shutdownOrExit() -
Method in class akka.remote.testconductor.Terminate
-
- shutdownOrExit() -
Method in class akka.remote.testconductor.TerminateMsg
-
- ShutdownTimeout() -
Method in class akka.actor.LightArrayRevolverScheduler
-
- shutdownTimeout() -
Method in class akka.dispatch.Dispatcher
-
- shutdownTimeout() -
Method in class akka.dispatch.MessageDispatcher
- When the dispatcher no longer has any actors registered, how long will it wait until it shuts itself down,
defaulting to your akka configs "akka.actor.default-dispatcher.shutdown-timeout" or default specified in
reference.conf
- ShutdownTimeout() -
Method in class akka.remote.RemoteSettings
-
- shutdownTimeout() -
Method in class akka.remote.testkit.MultiNodeSpec
-
- shutdownTimeout() -
Method in class akka.testkit.CallingThreadDispatcher
-
- shuttingDown() -
Method in class akka.contrib.pattern.ShardCoordinator
-
- SigarMetricsCollector - Class in akka.cluster
- Loads metrics through Hyperic SIGAR and JMX monitoring beans.
- SigarMetricsCollector(Address, double, Object) -
Constructor for class akka.cluster.SigarMetricsCollector
-
- SigarMetricsCollector(ActorSystem) -
Constructor for class akka.cluster.SigarMetricsCollector
- This constructor is used when creating an instance from configured FQCN
- signDeathPact(ActorRef) -
Method in class akka.io.TcpConnection
-
- simpleName(Object) -
Method in class akka.event.Logging$
- Returns a 'safe' getSimpleName for the provided object's Class
- simpleName(Class<?>) -
Method in class akka.event.Logging$
- Returns a 'safe' getSimpleName for the provided Class
- simpleName(Object) -
Static method in class akka.event.Logging
- Returns a 'safe' getSimpleName for the provided object's Class
- simpleName(Class<?>) -
Static method in class akka.event.Logging
- Returns a 'safe' getSimpleName for the provided Class
- simpleSender(Iterable<Inet.SocketOption>) -
Method in class akka.io.UdpMessage$
- Retrieve a reference to a “simple sender” actor of the UDP extension.
- simpleSender() -
Method in class akka.io.UdpMessage$
- Retrieve a simple sender without specifying options.
- simpleSender(Iterable<Inet.SocketOption>) -
Static method in class akka.io.UdpMessage
- Retrieve a reference to a “simple sender” actor of the UDP extension.
- simpleSender() -
Static method in class akka.io.UdpMessage
- Retrieve a simple sender without specifying options.
- SingleConsumerOnlyUnboundedMailbox - Class in akka.dispatch
- SingleConsumerOnlyUnboundedMailbox is a high-performance, multiple producer—single consumer, unbounded MailboxType,
with the drawback that you can't have multiple consumers,
which rules out using it with BalancingPool (BalancingDispatcher) for instance.
- SingleConsumerOnlyUnboundedMailbox() -
Constructor for class akka.dispatch.SingleConsumerOnlyUnboundedMailbox
-
- SingleConsumerOnlyUnboundedMailbox(ActorSystem.Settings, com.typesafe.config.Config) -
Constructor for class akka.dispatch.SingleConsumerOnlyUnboundedMailbox
-
- SingleConsumerOnlyUnboundedMailbox$ - Class in akka.dispatch
-
- SingleConsumerOnlyUnboundedMailbox$() -
Constructor for class akka.dispatch.SingleConsumerOnlyUnboundedMailbox$
-
- SingleExpectDefaultTimeout() -
Method in class akka.testkit.TestKitSettings
-
- singleton() -
Method in class akka.contrib.pattern.ClusterSingletonProxy
-
- singletonPath() -
Method in class akka.contrib.pattern.ClusterSingletonProxy
-
- size() -
Method in class akka.actor.mailbox.filebased.filequeue.Journal
-
- size() -
Method in class akka.dispatch.sysmsg.EarliestFirstSystemMessageList
- Indicates if the list is empty or not.
- size() -
Method in class akka.dispatch.sysmsg.LatestFirstSystemMessageList
- Indicates if the list is empty or not.
- size() -
Method in class akka.io.Inet.SO$.ReceiveBufferSize
-
- size() -
Method in class akka.io.Inet.SO$.SendBufferSize
-
- size() -
Method in class akka.util.BoundedBlockingQueue
-
- size() -
Method in class akka.util.Collections.PartialImmutableValuesIterable
-
- size() -
Method in class akka.util.SerializedSuspendableExecutionContext
- O(N)
- sizeHint(int) -
Method in class akka.util.ByteStringBuilder
-
- sizeInner(SystemMessage, int) -
Method in class akka.dispatch.sysmsg.SystemMessageList$
-
- sizeInner(SystemMessage, int) -
Static method in class akka.dispatch.sysmsg.SystemMessageList
-
- skipMemberStatus() -
Method in class akka.cluster.AutoDownBase
-
- Slf4jLogger - Class in akka.event.slf4j
- SLF4J logger.
- Slf4jLogger() -
Constructor for class akka.event.slf4j.Slf4jLogger
-
- SLF4JLogging - Interface in akka.event.slf4j
- Base trait for all classes that wants to be able use the SLF4J logging infrastructure.
- slice(int, int) -
Method in class akka.util.ByteIterator
-
- slice(int, int) -
Method in class akka.util.ByteString.ByteString1C
-
- slice(int, int) -
Method in class akka.util.ByteString
-
- smallBackoffCount() -
Method in class akka.remote.EndpointWriter
-
- SmallestMailboxPool - Class in akka.routing
- A router pool that tries to send to the non-suspended routee with fewest messages in mailbox.
- SmallestMailboxPool(int, Option<Resizer>, SupervisorStrategy, String, boolean) -
Constructor for class akka.routing.SmallestMailboxPool
-
- SmallestMailboxPool(com.typesafe.config.Config) -
Constructor for class akka.routing.SmallestMailboxPool
-
- SmallestMailboxPool$ - Class in akka.routing
-
- SmallestMailboxPool$() -
Constructor for class akka.routing.SmallestMailboxPool$
-
- SmallestMailboxRouter - Class in akka.routing
-
- SmallestMailboxRouter(int, Iterable<String>, Option<Resizer>, String, SupervisorStrategy) -
Constructor for class akka.routing.SmallestMailboxRouter
-
- SmallestMailboxRouter(int) -
Constructor for class akka.routing.SmallestMailboxRouter
- Java API: Constructor that sets nrOfInstances to be created.
- SmallestMailboxRouter(Iterable<String>) -
Constructor for class akka.routing.SmallestMailboxRouter
- Java API: Constructor that sets the routees to be used.
- SmallestMailboxRouter(Resizer) -
Constructor for class akka.routing.SmallestMailboxRouter
- Java API: Constructor that sets the resizer to be used.
- SmallestMailboxRouter$ - Class in akka.routing
-
- SmallestMailboxRouter$() -
Constructor for class akka.routing.SmallestMailboxRouter$
-
- SmallestMailboxRoutingLogic - Class in akka.routing
- Tries to send to the non-suspended routee with fewest messages in mailbox.
- SmallestMailboxRoutingLogic() -
Constructor for class akka.routing.SmallestMailboxRoutingLogic
-
- SmallestMailboxRoutingLogic$ - Class in akka.routing
-
- SmallestMailboxRoutingLogic$() -
Constructor for class akka.routing.SmallestMailboxRoutingLogic$
-
- smoothValue() -
Method in class akka.cluster.Metric
- The numerical value of the average, if defined, otherwise the latest value
- snapshot() -
Method in class akka.persistence.SelectedSnapshot
-
- Snapshot - Class in akka.persistence.serialization
- Wrapper for snapshot
data. - Snapshot(Object) -
Constructor for class akka.persistence.serialization.Snapshot
-
- snapshot() -
Method in class akka.persistence.SnapshotOffer
-
- snapshot() -
Method in class akka.persistence.SnapshotProtocol.LoadSnapshotResult
-
- snapshot() -
Method in class akka.persistence.SnapshotProtocol.SaveSnapshot
-
- Snapshot$ - Class in akka.persistence.serialization
-
- Snapshot$() -
Constructor for class akka.persistence.serialization.Snapshot$
-
- SnapshotHeader - Class in akka.persistence.serialization
- INTERNAL API.
- SnapshotHeader(int, Option<String>) -
Constructor for class akka.persistence.serialization.SnapshotHeader
-
- SnapshotHeader$ - Class in akka.persistence.serialization
-
- SnapshotHeader$() -
Constructor for class akka.persistence.serialization.SnapshotHeader$
-
- SnapshotInterval() -
Method in class akka.contrib.pattern.ClusterSharding.Settings$
-
- SnapshotMetadata - Class in akka.persistence
- Snapshot metadata.
- SnapshotMetadata(String, long, long) -
Constructor for class akka.persistence.SnapshotMetadata
-
- SnapshotMetadata$ - Class in akka.persistence
-
- SnapshotMetadata$() -
Constructor for class akka.persistence.SnapshotMetadata$
-
- SnapshotOffer - Class in akka.persistence
- Offers a
PersistentActor a previously saved snapshot during recovery. - SnapshotOffer(SnapshotMetadata, Object) -
Constructor for class akka.persistence.SnapshotOffer
-
- SnapshotOffer$ - Class in akka.persistence
-
- SnapshotOffer$() -
Constructor for class akka.persistence.SnapshotOffer$
-
- SnapshotProtocol - Class in akka.persistence
- INTERNAL API.
- SnapshotProtocol() -
Constructor for class akka.persistence.SnapshotProtocol
-
- SnapshotProtocol$ - Class in akka.persistence
- INTERNAL API.
- SnapshotProtocol$() -
Constructor for class akka.persistence.SnapshotProtocol$
-
- SnapshotProtocol.DeleteSnapshot - Class in akka.persistence
- Instructs snapshot store to delete a snapshot.
- SnapshotProtocol.DeleteSnapshot(SnapshotMetadata) -
Constructor for class akka.persistence.SnapshotProtocol.DeleteSnapshot
-
- SnapshotProtocol.DeleteSnapshot$ - Class in akka.persistence
-
- SnapshotProtocol.DeleteSnapshot$() -
Constructor for class akka.persistence.SnapshotProtocol.DeleteSnapshot$
-
- SnapshotProtocol.DeleteSnapshots - Class in akka.persistence
- Instructs snapshot store to delete all snapshots that match
criteria. - SnapshotProtocol.DeleteSnapshots(String, SnapshotSelectionCriteria) -
Constructor for class akka.persistence.SnapshotProtocol.DeleteSnapshots
-
- SnapshotProtocol.DeleteSnapshots$ - Class in akka.persistence
-
- SnapshotProtocol.DeleteSnapshots$() -
Constructor for class akka.persistence.SnapshotProtocol.DeleteSnapshots$
-
- SnapshotProtocol.LoadSnapshot - Class in akka.persistence
- Instructs a snapshot store to load a snapshot.
- SnapshotProtocol.LoadSnapshot(String, SnapshotSelectionCriteria, long) -
Constructor for class akka.persistence.SnapshotProtocol.LoadSnapshot
-
- SnapshotProtocol.LoadSnapshot$ - Class in akka.persistence
-
- SnapshotProtocol.LoadSnapshot$() -
Constructor for class akka.persistence.SnapshotProtocol.LoadSnapshot$
-
- SnapshotProtocol.LoadSnapshotResult - Class in akka.persistence
- Response message to a
SnapshotProtocol.LoadSnapshot message. - SnapshotProtocol.LoadSnapshotResult(Option<SelectedSnapshot>, long) -
Constructor for class akka.persistence.SnapshotProtocol.LoadSnapshotResult
-
- SnapshotProtocol.LoadSnapshotResult$ - Class in akka.persistence
-
- SnapshotProtocol.LoadSnapshotResult$() -
Constructor for class akka.persistence.SnapshotProtocol.LoadSnapshotResult$
-
- SnapshotProtocol.SaveSnapshot - Class in akka.persistence
- Instructs snapshot store to save a snapshot.
- SnapshotProtocol.SaveSnapshot(SnapshotMetadata, Object) -
Constructor for class akka.persistence.SnapshotProtocol.SaveSnapshot
-
- SnapshotProtocol.SaveSnapshot$ - Class in akka.persistence
-
- SnapshotProtocol.SaveSnapshot$() -
Constructor for class akka.persistence.SnapshotProtocol.SaveSnapshot$
-
- SnapshotSelectionCriteria - Class in akka.persistence
- Selection criteria for loading and deleting snapshots.
- SnapshotSelectionCriteria(long, long) -
Constructor for class akka.persistence.SnapshotSelectionCriteria
-
- SnapshotSelectionCriteria$ - Class in akka.persistence
-
- SnapshotSelectionCriteria$() -
Constructor for class akka.persistence.SnapshotSelectionCriteria$
-
- snapshotSequenceNr() -
Method in interface akka.persistence.Recovery
- Returns
lastSequenceNr.
- snapshotSequenceNr() -
Method in interface akka.persistence.Snapshotter
- Sequence number to use when taking a snapshot.
- SnapshotSerializer - Class in akka.persistence.serialization
Snapshot serializer.- SnapshotSerializer(ExtendedActorSystem) -
Constructor for class akka.persistence.serialization.SnapshotSerializer
-
- SnapshotSerializer$ - Class in akka.persistence.serialization
-
- SnapshotSerializer$() -
Constructor for class akka.persistence.serialization.SnapshotSerializer$
-
- SnapshotStore - Class in akka.persistence.snapshot.japi
- Java API: abstract snapshot store.
- SnapshotStore() -
Constructor for class akka.persistence.snapshot.japi.SnapshotStore
-
- SnapshotStore - Interface in akka.persistence.snapshot
- Abstract snapshot store.
- snapshotStore() -
Method in interface akka.persistence.snapshot.SnapshotStoreSpec
-
- snapshotStore() -
Method in interface akka.persistence.Snapshotter
-
- snapshotStoreFor(String) -
Method in class akka.persistence.Persistence
- Returns a snapshot store for a processor identified by
persistenceId.
- SnapshotStoreSpec - Interface in akka.persistence.snapshot
- This spec aims to verify custom akka-persistence
SnapshotStore implementations. - SnapshotStoreSpec$ - Class in akka.persistence.snapshot
-
- SnapshotStoreSpec$() -
Constructor for class akka.persistence.snapshot.SnapshotStoreSpec$
-
- snapshotTask() -
Method in class akka.contrib.pattern.ShardCoordinator
-
- Snapshotter - Interface in akka.persistence
- Snapshot API on top of the internal snapshot protocol.
- snapshotterId() -
Method in interface akka.persistence.PersistentView
- Returns
viewId.
- snapshotterId() -
Method in interface akka.persistence.ProcessorImpl
- Returns
persistenceId.
- snapshotterId() -
Method in class akka.persistence.RequestReader
-
- snapshotterId() -
Method in interface akka.persistence.Snapshotter
- Snapshotter id.
- snapshotterId() -
Method in interface akka.persistence.View
- Returns
viewId.
- snr() -
Method in class akka.persistence.journal.AsyncWriteJournal.Desequenced
-
- sockAddr() -
Method in interface akka.remote.testconductor.Conductor
- Obtain the port to which the controller’s socket is actually bound.
- socket(SocketType.ZMQSocketType) -
Method in class akka.zeromq.Context
-
- SocketConnectOption - Interface in akka.zeromq
- A base trait for connection options for a ZeroMQ socket
- SocketMeta - Interface in akka.zeromq
- Marker trait representing the base for all meta operations for a socket
such as the context, listener, socket type and poller dispatcher
- SocketOption - Interface in akka.zeromq
- Marker trait representing the base for all socket options
- SocketOptionQuery - Interface in akka.zeromq
- A marker trait to group option queries together
- SocketType - Class in akka.zeromq
- The different socket types you can create with zeromq
- SocketType() -
Constructor for class akka.zeromq.SocketType
-
- SocketType$ - Class in akka.zeromq
- The different socket types you can create with zeromq
- SocketType$() -
Constructor for class akka.zeromq.SocketType$
-
- SocketType.Dealer$ - Class in akka.zeromq
- A dealer socket
- SocketType.Dealer$() -
Constructor for class akka.zeromq.SocketType.Dealer$
-
- SocketType.Pair$ - Class in akka.zeromq
- A Pair socket
- SocketType.Pair$() -
Constructor for class akka.zeromq.SocketType.Pair$
-
- SocketType.Pub$ - Class in akka.zeromq
- A Publisher socket
- SocketType.Pub$() -
Constructor for class akka.zeromq.SocketType.Pub$
-
- SocketType.Pull$ - Class in akka.zeromq
- A pull socket
- SocketType.Pull$() -
Constructor for class akka.zeromq.SocketType.Pull$
-
- SocketType.Push$ - Class in akka.zeromq
- A push socket
- SocketType.Push$() -
Constructor for class akka.zeromq.SocketType.Push$
-
- SocketType.Rep$ - Class in akka.zeromq
- A reply socket
- SocketType.Rep$() -
Constructor for class akka.zeromq.SocketType.Rep$
-
- SocketType.Req$ - Class in akka.zeromq
- A request socket
- SocketType.Req$() -
Constructor for class akka.zeromq.SocketType.Req$
-
- SocketType.Router$ - Class in akka.zeromq
- A router socket
- SocketType.Router$() -
Constructor for class akka.zeromq.SocketType.Router$
-
- SocketType.Sub$ - Class in akka.zeromq
- A subscriber socket
- SocketType.Sub$() -
Constructor for class akka.zeromq.SocketType.Sub$
-
- SocketType.ZMQSocketType - Class in akka.zeromq
-
- SocketType.ZMQSocketType(int) -
Constructor for class akka.zeromq.SocketType.ZMQSocketType
-
- SocketUtil - Class in akka.testkit
- Utilities to get free socket address.
- SocketUtil() -
Constructor for class akka.testkit.SocketUtil
-
- SocketUtil$ - Class in akka.testkit
- Utilities to get free socket address.
- SocketUtil$() -
Constructor for class akka.testkit.SocketUtil$
-
- some(A) -
Method in class akka.japi.Option$
Option factory that creates Some
- some(A) -
Static method in class akka.japi.Option
Option factory that creates Some
- sort(Iterable<Tuple2<Class<? extends Throwable>, SupervisorStrategy.Directive>>) -
Method in class akka.actor.SupervisorStrategy$
- Sort so that subtypes always precede their supertypes, but without
obeying any order between unrelated subtypes (insert sort).
- sort(Iterable<Tuple2<Class<? extends Throwable>, SupervisorStrategy.Directive>>) -
Static method in class akka.actor.SupervisorStrategy
- Sort so that subtypes always precede their supertypes, but without
obeying any order between unrelated subtypes (insert sort).
- source() -
Method in class akka.testkit.DebugFilter
-
- source() -
Method in class akka.testkit.ErrorFilter
-
- source() -
Method in class akka.testkit.EventFilter
-
- source() -
Method in class akka.testkit.InfoFilter
-
- source() -
Method in class akka.testkit.WarningFilter
-
- span(Function1<Object, Object>) -
Method in class akka.util.ByteIterator
-
- span(Function1<Object, Object>) -
Method in class akka.util.ByteString
-
- spawn(String, Function0<BoxedUnit>) -
Method in class akka.testkit.AkkaSpec
-
- spawnChildWithCapacityProtection(SelectionHandler.WorkerForCommand, int) -
Method in class akka.io.SelectionHandler
-
- specialHandle(Object, ActorRef) -
Method in class akka.actor.DeadLetterActorRef
-
- specialHandle(Object, ActorRef) -
Method in class akka.actor.EmptyLocalActorRef
-
- split(String, String) -
Method in interface akka.actor.PathUtils
-
- splitAt(int) -
Method in class akka.util.ByteString
-
- splitNameAndUid(String) -
Method in class akka.actor.ActorCell$
-
- splitNameAndUid(String) -
Static method in class akka.actor.ActorCell
-
- squaredIntervalSum() -
Method in class akka.remote.HeartbeatHistory
-
- SSLEnabledAlgorithms() -
Method in class akka.remote.transport.netty.SSLSettings
-
- SSLKeyPassword() -
Method in class akka.remote.transport.netty.SSLSettings
-
- SSLKeyStore() -
Method in class akka.remote.transport.netty.SSLSettings
-
- SSLKeyStorePassword() -
Method in class akka.remote.transport.netty.SSLSettings
-
- SSLProtocol() -
Method in class akka.remote.transport.netty.SSLSettings
-
- SSLRandomNumberGenerator() -
Method in class akka.remote.transport.netty.SSLSettings
-
- SslSettings() -
Method in class akka.remote.transport.netty.NettyTransportSettings
-
- SSLSettings - Class in akka.remote.transport.netty
- INTERNAL API
- SSLSettings(com.typesafe.config.Config) -
Constructor for class akka.remote.transport.netty.SSLSettings
-
- SSLTrustStore() -
Method in class akka.remote.transport.netty.SSLSettings
-
- SSLTrustStorePassword() -
Method in class akka.remote.transport.netty.SSLSettings
-
- stackTraceFor(Throwable) -
Method in class akka.event.Logging$
- Returns the StackTrace for the given Throwable as a String
- stackTraceFor(Throwable) -
Static method in class akka.event.Logging
- Returns the StackTrace for the given Throwable as a String
- StandardMetrics - Class in akka.cluster
- Definitions of the built-in standard metrics.
- StandardMetrics() -
Constructor for class akka.cluster.StandardMetrics
-
- StandardMetrics$ - Class in akka.cluster
- Definitions of the built-in standard metrics.
- StandardMetrics$() -
Constructor for class akka.cluster.StandardMetrics$
-
- StandardMetrics.Cpu - Class in akka.cluster
-
- StandardMetrics.Cpu(Address, long, Option<Object>, Option<Object>, int) -
Constructor for class akka.cluster.StandardMetrics.Cpu
-
- StandardMetrics.Cpu$ - Class in akka.cluster
-
- StandardMetrics.Cpu$() -
Constructor for class akka.cluster.StandardMetrics.Cpu$
-
- StandardMetrics.HeapMemory - Class in akka.cluster
-
- StandardMetrics.HeapMemory(Address, long, long, long, Option<Object>) -
Constructor for class akka.cluster.StandardMetrics.HeapMemory
-
- StandardMetrics.HeapMemory$ - Class in akka.cluster
-
- StandardMetrics.HeapMemory$() -
Constructor for class akka.cluster.StandardMetrics.HeapMemory$
-
- StandardOutLogger() -
Method in class akka.event.Logging$
-
- StandardOutLogger() -
Static method in class akka.event.Logging
-
- start() -
Method in class akka.actor.ActorSystemImpl
-
- start() -
Method in interface akka.actor.Cell
- Start the cell: enqueued message must not be processed before this has
been called.
- start() -
Method in interface akka.actor.dungeon.Dispatch
- Start this cell, i.e.
- start() -
Method in class akka.actor.InternalActorRef
-
- start() -
Method in class akka.actor.LocalActorRef
- Starts the actor after initialization.
- start() -
Method in interface akka.actor.MinimalActorRef
-
- start() -
Method in class akka.actor.RepointableActorRef
-
- start() -
Method in class akka.actor.UnstartedCell
-
- start() -
Method in class akka.camel.internal.DefaultCamel
- Starts camel and underlying camel context and template.
- start(String, Option<Props>, PartialFunction<Object, Tuple2<String, Object>>, Function1<Object, String>, ShardCoordinator.ShardAllocationStrategy) -
Method in class akka.contrib.pattern.ClusterSharding
- Scala API: Register a named entry type by defining the
Props of the entry actor
and functions to extract entry and shard identifier from messages.
- start(String, Option<Props>, PartialFunction<Object, Tuple2<String, Object>>, Function1<Object, String>) -
Method in class akka.contrib.pattern.ClusterSharding
- Register a named entry type by defining the
Props of the entry actor and
functions to extract entry and shard identifier from messages.
- start(String, Props, ShardRegion.MessageExtractor, ShardCoordinator.ShardAllocationStrategy) -
Method in class akka.contrib.pattern.ClusterSharding
- Java API: Register a named entry type by defining the
Props of the entry actor
and functions to extract entry and shard identifier from messages.
- start(String, Props, ShardRegion.MessageExtractor) -
Method in class akka.contrib.pattern.ClusterSharding
- Java API: Register a named entry type by defining the
Props of the entry actor
and functions to extract entry and shard identifier from messages.
- start(org.osgi.framework.BundleContext) -
Method in class akka.osgi.ActorSystemActivator
- Sets up a new ActorSystem
- start() -
Method in class akka.remote.RemoteActorRef
-
- start() -
Method in class akka.remote.RemoteTransport
- Start up the transport, i.e.
- start() -
Method in class akka.remote.Remoting
-
- start() -
Method in class akka.routing.RoutedActorCell
-
- startAndStopDuration() -
Method in interface akka.testkit.WatchedByCoroner
-
- startClient(RoleName, InetSocketAddress) -
Method in interface akka.remote.testconductor.Player
- Connect to the conductor on the given port (the host is taken from setting
akka.testconductor.host).
- startController(int, RoleName, InetSocketAddress) -
Method in interface akka.remote.testconductor.Conductor
- Start the
Controller, which in turn will
bind to a TCP port as specified in the akka.testconductor.port config
property, where 0 denotes automatic allocation.
- startCoordinator() -
Method in class akka.contrib.pattern.ShardCoordinatorSupervisor
-
- startCoroner() -
Method in interface akka.testkit.WatchedByCoroner
-
- startDefaultLoggers(ActorSystemImpl) -
Method in interface akka.event.LoggingBus
- Internal Akka use only
- startHash(int) -
Method in class akka.routing.MurmurHash$
- Begin a new hash with a seed value.
- startHash(int) -
Static method in class akka.routing.MurmurHash
- Begin a new hash with a seed value.
- startMagicA() -
Method in class akka.routing.MurmurHash$
- The initial magic integers in the first stream.
- startMagicA() -
Static method in class akka.routing.MurmurHash
- The initial magic integers in the first stream.
- startMagicB() -
Method in class akka.routing.MurmurHash$
- The initial magic integer in the second stream.
- startMagicB() -
Static method in class akka.routing.MurmurHash
- The initial magic integer in the second stream.
- startNewSystem() -
Method in class akka.remote.testkit.MultiNodeSpec
- This method starts a new ActorSystem with the same configuration as the
previous one on the current node, including deployments.
- startReadBehind() -
Method in class akka.actor.mailbox.filebased.filequeue.Journal
-
- startStdoutLogger(ActorSystem.Settings) -
Method in interface akka.event.LoggingBus
- Internal Akka use only
- startsWith(String) -
Method in class akka.testkit.JavaTestKit.EventFilter
-
- startTick() -
Method in class akka.actor.LightArrayRevolverScheduler
- Replaceable for testing.
- startTime() -
Method in class akka.actor.ActorSystem
- Start-up time in milliseconds since the epoch.
- startup() -
Method in interface akka.kernel.Bootable
- Callback run on microkernel startup.
- StartupTimeout() -
Method in class akka.remote.RemoteSettings
-
- startWith(S, D) -
Method in class akka.actor.AbstractFSM
- Set initial state.
- startWith(S, D, FiniteDuration) -
Method in class akka.actor.AbstractFSM
- Set initial state.
- startWith(S, D, Option<FiniteDuration>) -
Method in interface akka.actor.FSM
- Set initial state.
- stash(SystemMessage) -
Method in class akka.actor.ActorCell
-
- Stash - Interface in akka.actor
- The
Stash trait enables an actor to temporarily stash away messages that can not or
should not be handled using the actor's current behavior. - stash() -
Method in interface akka.actor.StashSupport
- Adds the current message (the message that the actor received last) to the
actor's stash.
- stashedInbound() -
Method in class akka.remote.EndpointManager
-
- StashFactory - Interface in akka.actor
- INTERNAL API.
- StashOverflowException - Exception in akka.actor
- Is thrown when the size of the Stash exceeds the capacity of the Stash
- StashOverflowException(String, Throwable) -
Constructor for exception akka.actor.StashOverflowException
-
- StashOverflowException$ - Class in akka.actor
-
- StashOverflowException$() -
Constructor for class akka.actor.StashOverflowException$
-
- StashSupport - Interface in akka.actor
- INTERNAL API.
- StashWhenFailed - Interface in akka.dispatch.sysmsg
- INTERNAL API
- StashWhenWaitingForChildren - Interface in akka.dispatch.sysmsg
- INTERNAL API
- state() -
Method in class akka.actor.FSM.CurrentState
-
- state() -
Method in class akka.cluster.Cluster
- Current snapshot state of the cluster.
- state() -
Method in class akka.cluster.ClusterHeartbeatSender
-
- state() -
Method in class akka.cluster.ClusterReadView
-
- state(S, S, FI.UnitApplyVoid) -
Method in class akka.japi.pf.FSMTransitionHandlerBuilder
- Add a case statement that matches on a from state and a to state.
- state(S, S, FI.UnitApply2<S, S>) -
Method in class akka.japi.pf.FSMTransitionHandlerBuilder
- Add a case statement that matches on a from state and a to state.
- stateData() -
Method in class akka.actor.FSM.Event
-
- stateData() -
Method in class akka.actor.FSM.LogEntry
-
- stateData() -
Method in class akka.actor.FSM.State
-
- stateData() -
Method in interface akka.actor.FSM
-
- stateData() -
Method in class akka.actor.FSM.StopEvent
-
- stateData() -
Method in class akka.testkit.TestFSMRef
- Get current state data of this FSM.
- stateFunctions() -
Method in interface akka.actor.FSM
-
- stateName() -
Method in class akka.actor.FSM.LogEntry
-
- stateName() -
Method in class akka.actor.FSM.State
-
- stateName() -
Method in interface akka.actor.FSM
-
- stateName() -
Method in class akka.testkit.TestFSMRef
- Get current state name of this FSM.
- states() -
Method in interface akka.actor.LoggingFSM
-
- StateTimeout() -
Method in interface akka.actor.FSM
- This case object is received in case of a state timeout.
- stateTimeouts() -
Method in interface akka.actor.FSM
-
- stats() -
Method in interface akka.actor.dungeon.ChildrenContainer.EmptyChildrenContainer
-
- stats() -
Method in class akka.actor.dungeon.ChildrenContainer.NormalChildrenContainer
-
- stats() -
Method in interface akka.actor.dungeon.ChildrenContainer
-
- stats() -
Method in class akka.actor.dungeon.ChildrenContainer.TerminatingChildrenContainer
-
- stats(String) -
Method in class akka.actor.mailbox.filebased.filequeue.QueueCollection
-
- statsEnabled() -
Method in class akka.cluster.ClusterCoreDaemon
-
- Status - Class in akka.actor
- Classes for passing status back to the sender.
- Status() -
Constructor for class akka.actor.Status
-
- status() -
Method in class akka.actor.Status.Success
-
- status() -
Method in class akka.cluster.ClusterReadView
- Member status for this node (
MemberStatus).
- status() -
Method in class akka.cluster.Member
-
- status() -
Method in class akka.cluster.Reachability.Record
-
- status(UniqueAddress, UniqueAddress) -
Method in class akka.cluster.Reachability
-
- status(UniqueAddress) -
Method in class akka.cluster.Reachability
-
- status() -
Method in class akka.remote.EndpointManager.ManagementCommandAck
-
- Status$ - Class in akka.actor
- Classes for passing status back to the sender.
- Status$() -
Constructor for class akka.actor.Status$
-
- Status.Failure - Class in akka.actor
- This class/message type is preferably used to indicate failure of some operation performed.
- Status.Failure(Throwable) -
Constructor for class akka.actor.Status.Failure
-
- Status.Failure$ - Class in akka.actor
-
- Status.Failure$() -
Constructor for class akka.actor.Status.Failure$
-
- Status.Status - Interface in akka.actor
-
- Status.Success - Class in akka.actor
- This class/message type is preferably used to indicate success of some operation performed.
- Status.Success(Object) -
Constructor for class akka.actor.Status.Success
-
- Status.Success$ - Class in akka.actor
-
- Status.Success$() -
Constructor for class akka.actor.Status.Success$
-
- STATUS_FIELD_NUMBER -
Static variable in class akka.cluster.protobuf.msg.ClusterMessages.Member
-
- STATUS_FIELD_NUMBER -
Static variable in class akka.cluster.protobuf.msg.ClusterMessages.SubjectReachability
-
- statusFuture() -
Method in class akka.remote.transport.netty.ClientHandler
-
- statusPromise() -
Method in class akka.remote.transport.ActorTransportAdapter.AssociateUnderlying
-
- statusPromise() -
Method in class akka.remote.transport.AkkaProtocolTransport.AssociateUnderlyingRefuseUid
-
- statusPromise() -
Method in class akka.remote.transport.netty.ClientHandler
-
- statusPromise() -
Method in class akka.remote.transport.ProtocolStateActor.OutboundUnassociated
-
- statusPromise() -
Method in class akka.remote.transport.ProtocolStateActor.OutboundUnderlyingAssociated
-
- statusPromise() -
Method in class akka.remote.transport.ThrottlerManager.AssociateResult
-
- stay() -
Method in interface akka.actor.FSM
- Produce "empty" transition descriptor.
- stdDeviation() -
Method in class akka.remote.HeartbeatHistory
-
- StdoutLogLevel() -
Method in class akka.actor.ActorSystem.Settings
-
- stop(ActorRef) -
Method in interface akka.actor.ActorRefFactory
- Stop the actor pointed to by the given
ActorRef; this is
an asynchronous operation, i.e.
- stop(ActorRef) -
Method in class akka.actor.ActorSystemImpl
-
- stop() -
Method in interface akka.actor.Cell
- Recursively terminate this actor and all its children.
- Stop() -
Method in interface akka.actor.dsl.Creators.Act
-
- stop(ActorRef) -
Method in interface akka.actor.dungeon.Children
-
- stop() -
Method in interface akka.actor.dungeon.Dispatch
-
- stop() -
Method in interface akka.actor.FSM
- Produce change descriptor to stop this FSM actor with reason "Normal".
- stop(FSM.Reason) -
Method in interface akka.actor.FSM
- Produce change descriptor to stop this FSM actor including specified reason.
- stop(FSM.Reason, D) -
Method in interface akka.actor.FSM
- Produce change descriptor to stop this FSM actor including specified reason.
- stop() -
Method in class akka.actor.InternalActorRef
-
- stop() -
Method in class akka.actor.LocalActorRef
- Shuts down the actor and its message queue
- stop() -
Method in interface akka.actor.MinimalActorRef
-
- stop() -
Method in class akka.actor.RepointableActorRef
-
- stop() -
Method in class akka.actor.SupervisorStrategy$
- Java API: Returning this directive stops the Actor
- stop() -
Static method in class akka.actor.SupervisorStrategy
- Java API: Returning this directive stops the Actor
- stop(Object) -
Method in interface akka.actor.TypedActorFactory
- Stops the underlying ActorRef for the supplied TypedActor proxy,
if any, returns whether it could find the find the ActorRef or not
- stop() -
Method in class akka.actor.UnstartedCell
-
- stop(FSM.Reason, FI.UnitApply2<S, D>) -
Method in class akka.japi.pf.FSMStopBuilder
- Add a case statement that matches on an
FSM.Reason.
- stop(Class<P>, FI.UnitApply3<P, S, D>) -
Method in class akka.japi.pf.FSMStopBuilder
- Add a case statement that matches on a reason type.
- stop(Class<P>, FI.TypedPredicate<P>, FI.UnitApply3<P, S, D>) -
Method in class akka.japi.pf.FSMStopBuilder
- Add a case statement that matches on a reason type and a predicate.
- stop(org.osgi.framework.BundleContext) -
Method in class akka.osgi.ActorSystemActivator
- Shuts down the ActorSystem when the bundle is stopped and, if necessary, unregisters a service registration.
- stop() -
Method in class akka.pattern.PromiseActorRef
-
- stop() -
Method in class akka.remote.RemoteActorRef
-
- StopChild - Class in akka.actor
- Internal Akka use only, used in implementation of system.stop(child).
- StopChild(ActorRef) -
Constructor for class akka.actor.StopChild
-
- StopChild$ - Class in akka.actor
-
- StopChild$() -
Constructor for class akka.actor.StopChild$
-
- stopCoroner() -
Method in interface akka.testkit.WatchedByCoroner
-
- stopDefaultLoggers(ActorSystem) -
Method in interface akka.event.LoggingBus
- Internal Akka use only
- StopEvent() -
Method in interface akka.actor.FSM
-
- stopIfAllRouteesRemoved() -
Method in class akka.routing.RouterActor
-
- stopMessage() -
Method in class akka.contrib.pattern.ShardRegion.Passivate
-
- stoppingShard() -
Method in class akka.contrib.pattern.ShardCoordinator.RebalanceWorker
-
- stoppingStrategy() -
Method in class akka.actor.SupervisorStrategy$
- This strategy resembles Erlang in that failing children are always
terminated (one-for-one).
- stoppingStrategy() -
Static method in class akka.actor.SupervisorStrategy
- This strategy resembles Erlang in that failing children are always
terminated (one-for-one).
- StoppingSupervisorStrategy - Class in akka.actor
-
- StoppingSupervisorStrategy() -
Constructor for class akka.actor.StoppingSupervisorStrategy
-
- stopReason() -
Method in class akka.actor.FSM.State
-
- stopReason() -
Method in class akka.remote.EndpointWriter
-
- stopRouterWhenAllRouteesRemoved() -
Method in interface akka.cluster.routing.ClusterRouterConfigBase
-
- stopRouterWhenAllRouteesRemoved() -
Method in interface akka.routing.Pool
-
- stopRouterWhenAllRouteesRemoved() -
Method in interface akka.routing.RouterConfig
-
- stopScheduler() -
Method in class akka.actor.ActorSystemImpl
-
- stopSeedNodeProcess() -
Method in class akka.cluster.ClusterCoreDaemon
-
- stopWith(TcpConnection.CloseInformation) -
Method in class akka.io.TcpConnection
-
- store() -
Method in interface akka.persistence.journal.AsyncWriteProxy
-
- StreamingCache() -
Method in class akka.camel.CamelSettings
- enables or disables streamingCache on the Camel Context
- streamMustContain(InputStream, String) -
Method in class akka.actor.mailbox.DurableMailboxSpec
-
- stringHash(String) -
Method in class akka.routing.MurmurHash$
- Compute a high-quality hash of a string
- stringHash(String) -
Static method in class akka.routing.MurmurHash
- Compute a high-quality hash of a string
- SubchannelClassification - Interface in akka.event
- Classification which respects relationships between channels: subscribing
to one channel automatically and idempotently subscribes to all sub-channels.
- SubchannelEventBus<E,S,C> - Class in akka.event.japi
- See documentation for
SubchannelClassification
E is the Event type
S is the Subscriber type
C is the Classifier type - SubchannelEventBus() -
Constructor for class akka.event.japi.SubchannelEventBus
-
- subclassification() -
Method in class akka.event.EventStream
-
- subclassification() -
Method in class akka.event.japi.SubchannelEventBus
- The logic to form sub-class hierarchy
- subclassification() -
Method in interface akka.event.SubchannelClassification
- The logic to form sub-class hierarchy
- Subclassification<K> - Interface in akka.util
- Typeclass which describes a classification hierarchy.
- SubclassifiedIndex<K,V> - Class in akka.util
- Mutable index which respects sub-class relationships between keys:
- SubclassifiedIndex(Subclassification<K>) -
Constructor for class akka.util.SubclassifiedIndex
-
- SubclassifiedIndex$ - Class in akka.util
-
- SubclassifiedIndex$() -
Constructor for class akka.util.SubclassifiedIndex$
-
- SubclassifiedIndex.Nonroot<K,V> - Class in akka.util
-
- SubclassifiedIndex.Nonroot(SubclassifiedIndex<K, V>, K, Set<V>, Subclassification<K>) -
Constructor for class akka.util.SubclassifiedIndex.Nonroot
-
- subject() -
Method in class akka.cluster.Reachability.Record
-
- SUBJECTREACHABILITY_FIELD_NUMBER -
Static variable in class akka.cluster.protobuf.msg.ClusterMessages.ObserverReachability
-
- subkeys() -
Method in class akka.util.SubclassifiedIndex
-
- submit(Callable<T>) -
Method in interface akka.dispatch.ExecutorServiceDelegate
-
- submit(Runnable, T) -
Method in interface akka.dispatch.ExecutorServiceDelegate
-
- submit(Runnable) -
Method in interface akka.dispatch.ExecutorServiceDelegate
-
- subscribe(ActorRef, Class<?>...) -
Method in class akka.cluster.Cluster
- Subscribe to one or more cluster domain events.
- subscribe(ActorRef, ClusterEvent.SubscriptionInitialStateMode, Class<?>...) -
Method in class akka.cluster.Cluster
- Subscribe to one or more cluster domain events.
- subscribe(ActorRef, Seq<Class<?>>) -
Method in class akka.cluster.Cluster
- Subscribe to one or more cluster domain events.
- subscribe(ActorRef, ClusterEvent.SubscriptionInitialStateMode, Seq<Class<?>>) -
Method in class akka.cluster.Cluster
- Subscribe to one or more cluster domain events.
- subscribe(ActorRef, ClusterEvent.SubscriptionInitialStateMode, Set<Class<?>>) -
Method in class akka.cluster.ClusterDomainEventPublisher
-
- subscribe() -
Method in class akka.contrib.pattern.DistributedPubSubMediator.SubscribeAck
-
- subscribe(ActorRef, ActorRef) -
Method in interface akka.event.ActorClassification
-
- subscribe(ActorRef) -
Method in class akka.event.AddressTerminatedTopic
-
- subscribe(EventBus, EventBus) -
Method in interface akka.event.EventBus
-
- subscribe(ActorRef, Class<?>) -
Method in class akka.event.EventStream
-
- subscribe(ActorRef, ActorRef) -
Method in class akka.event.japi.ActorEventBus
-
- subscribe(S, C) -
Method in interface akka.event.japi.EventBus
- Attempts to register the subscriber to the specified Classifier
- subscribe(S, C) -
Method in class akka.event.japi.LookupEventBus
-
- subscribe(S, C) -
Method in class akka.event.japi.ScanningEventBus
-
- subscribe(S, C) -
Method in class akka.event.japi.SubchannelEventBus
-
- subscribe(LookupClassification, LookupClassification) -
Method in interface akka.event.LookupClassification
-
- subscribe(ScanningClassification, ScanningClassification) -
Method in interface akka.event.ScanningClassification
-
- subscribe(SubchannelClassification, SubchannelClassification) -
Method in interface akka.event.SubchannelClassification
-
- subscribe(ActorRef, ClassTag<T>) -
Method in interface akka.persistence.PluginSpec
-
- Subscribe - Class in akka.zeromq
- The
Subscribe option establishes a new message filter on a akka.zeromq.SocketType.Pub socket. - Subscribe(ByteString) -
Constructor for class akka.zeromq.Subscribe
-
- Subscribe(String) -
Constructor for class akka.zeromq.Subscribe
-
- Subscribe$ - Class in akka.zeromq
-
- Subscribe$() -
Constructor for class akka.zeromq.Subscribe$
-
- subscribeAddressTerminated() -
Method in interface akka.actor.dungeon.DeathWatch
-
- subscriber() -
Method in class akka.cluster.InternalClusterAction.Subscribe
-
- subscriber() -
Method in class akka.cluster.InternalClusterAction.Unsubscribe
-
- subscriber() -
Method in class akka.contrib.pattern.DistributedPubSubMediator.Internal$.Subscribed
-
- subscriber() -
Method in class akka.contrib.pattern.DistributedPubSubMediator.Internal$.Unsubscribed
-
- subscribers() -
Method in interface akka.contrib.pattern.DistributedPubSubMediator.Internal$.TopicLike
-
- subscribers() -
Method in interface akka.event.LookupClassification
-
- subscribers() -
Method in interface akka.event.ScanningClassification
-
- subscriptions() -
Method in interface akka.event.SubchannelClassification
-
- Succeeded_VALUE -
Static variable in enum akka.remote.testconductor.TestConductorProtocol.BarrierOp
Succeeded = 3;
- success() -
Method in class akka.remote.testconductor.BarrierResult
-
- successful(T) -
Method in class akka.dispatch.Futures$
- Creates an already completed Promise with the specified result
- successful(T) -
Static method in class akka.dispatch.Futures
- Creates an already completed Promise with the specified result
- Supervise - Class in akka.dispatch.sysmsg
- INTERNAL API
- Supervise(ActorRef, boolean) -
Constructor for class akka.dispatch.sysmsg.Supervise
-
- Supervise$ - Class in akka.dispatch.sysmsg
-
- Supervise$() -
Constructor for class akka.dispatch.sysmsg.Supervise$
-
- superviseWith(SupervisorStrategy) -
Method in interface akka.actor.dsl.Creators.Act
- Set the supervisor strategy of this actor, i.e.
- supervisor() -
Method in class akka.actor.RepointableActorRef
-
- supervisor() -
Method in class akka.actor.UnstartedCell
-
- supervisor() -
Method in interface akka.camel.Camel
- INTERNAL API
Returns the camel supervisor actor.
- supervisor() -
Method in class akka.camel.internal.DefaultCamel
-
- supervisor() -
Method in class akka.remote.DaemonMsgCreate
-
- supervisor() -
Method in class akka.remote.RemoteDeploymentWatcher.WatchRemote
-
- SUPERVISOR_FIELD_NUMBER -
Static variable in class akka.remote.WireFormats.DaemonMsgCreateData
-
- supervisors() -
Method in class akka.remote.RemoteDeploymentWatcher
-
- supervisorStrategy() -
Method in interface akka.actor.Actor
- User overridable definition the strategy to use for supervising
child actors.
- supervisorStrategy() -
Method in interface akka.actor.dsl.Creators.Act
-
- SupervisorStrategy - Class in akka.actor
- An Akka SupervisorStrategy is the policy to apply for crashing children.
- SupervisorStrategy() -
Constructor for class akka.actor.SupervisorStrategy
-
- supervisorStrategy() -
Method in interface akka.actor.TypedActor.Supervisor
- User overridable definition the strategy to use for supervising
child actors.
- supervisorStrategy() -
Method in class akka.actor.TypedActor.TypedActor
-
- supervisorStrategy() -
Method in class akka.actor.UntypedActor
- User overridable definition the strategy to use for supervising
child actors.
- supervisorStrategy() -
Method in class akka.camel.internal.CamelSupervisor
-
- supervisorStrategy() -
Method in class akka.camel.internal.Registry
-
- supervisorStrategy() -
Method in class akka.cluster.ClusterCoreSupervisor
-
- supervisorStrategy() -
Method in class akka.cluster.routing.AdaptiveLoadBalancingPool
-
- supervisorStrategy() -
Method in class akka.cluster.routing.AdaptiveLoadBalancingRouter
-
- supervisorStrategy() -
Method in class akka.cluster.routing.ClusterRouterConfig
-
- supervisorStrategy() -
Method in class akka.cluster.routing.ClusterRouterPool
-
- supervisorStrategy() -
Method in class akka.contrib.pattern.ReliableProxy
-
- supervisorStrategy() -
Method in class akka.io.SelectionHandler.SelectorBasedManager
-
- supervisorStrategy() -
Method in class akka.io.SelectionHandler
-
- supervisorStrategy() -
Method in class akka.io.TcpListener
-
- supervisorStrategy() -
Method in class akka.remote.EndpointManager
-
- supervisorStrategy() -
Method in class akka.remote.EndpointWriter
-
- supervisorStrategy() -
Method in class akka.remote.ReliableDeliverySupervisor
-
- supervisorStrategy() -
Method in class akka.remote.Remoting.TransportSupervisor
-
- supervisorStrategy() -
Method in class akka.remote.routing.RemoteRouterConfig
-
- supervisorStrategy() -
Method in class akka.remote.testconductor.Controller
-
- supervisorStrategy() -
Method in class akka.remote.transport.AkkaProtocolManager
-
- supervisorStrategy() -
Method in class akka.routing.BalancingPool
-
- supervisorStrategy() -
Method in class akka.routing.BroadcastPool
-
- supervisorStrategy() -
Method in class akka.routing.BroadcastRouter
-
- supervisorStrategy() -
Method in class akka.routing.ConsistentHashingPool
-
- supervisorStrategy() -
Method in class akka.routing.ConsistentHashingRouter
-
- supervisorStrategy() -
Method in class akka.routing.FromConfig
-
- supervisorStrategy() -
Method in interface akka.routing.Pool
- SupervisorStrategy for the head actor, i.e.
- supervisorStrategy() -
Method in class akka.routing.RandomPool
-
- supervisorStrategy() -
Method in class akka.routing.RandomRouter
-
- supervisorStrategy() -
Method in class akka.routing.RoundRobinPool
-
- supervisorStrategy() -
Method in class akka.routing.RoundRobinRouter
-
- supervisorStrategy() -
Method in class akka.routing.RouterPoolActor
-
- supervisorStrategy() -
Method in class akka.routing.ScatterGatherFirstCompletedPool
-
- supervisorStrategy() -
Method in class akka.routing.ScatterGatherFirstCompletedRouter
-
- supervisorStrategy() -
Method in class akka.routing.SmallestMailboxPool
-
- supervisorStrategy() -
Method in class akka.routing.SmallestMailboxRouter
-
- supervisorStrategy() -
Method in class akka.routing.TailChoppingPool
-
- SupervisorStrategy$ - Class in akka.actor
-
- SupervisorStrategy$() -
Constructor for class akka.actor.SupervisorStrategy$
-
- SupervisorStrategy.Directive - Interface in akka.actor
-
- SupervisorStrategy.Escalate$ - Class in akka.actor
- Escalates the failure to the supervisor of the supervisor,
by rethrowing the cause of the failure, i.e.
- SupervisorStrategy.Escalate$() -
Constructor for class akka.actor.SupervisorStrategy.Escalate$
-
- SupervisorStrategy.Restart$ - Class in akka.actor
- Discards the old Actor instance and replaces it with a new,
then resumes message processing.
- SupervisorStrategy.Restart$() -
Constructor for class akka.actor.SupervisorStrategy.Restart$
-
- SupervisorStrategy.Resume$ - Class in akka.actor
- Resumes message processing for the failed Actor
- SupervisorStrategy.Resume$() -
Constructor for class akka.actor.SupervisorStrategy.Resume$
-
- SupervisorStrategy.Stop$ - Class in akka.actor
- Stops the Actor
- SupervisorStrategy.Stop$() -
Constructor for class akka.actor.SupervisorStrategy.Stop$
-
- SupervisorStrategyClass() -
Method in class akka.actor.ActorSystem.Settings
-
- SupervisorStrategyConfigurator - Interface in akka.actor
- Implement this interface in order to configure the supervisorStrategy for
the top-level guardian actor (
/user). - SupervisorStrategyLowPriorityImplicits - Interface in akka.actor
-
- SuppressedDeadLetter - Class in akka.actor
- Similar to
DeadLetter with the slight twist of NOT being logged by the default dead letters listener. - SuppressedDeadLetter(DeadLetterSuppression, ActorRef, ActorRef) -
Constructor for class akka.actor.SuppressedDeadLetter
-
- SuppressedDeadLetter$ - Class in akka.actor
-
- SuppressedDeadLetter$() -
Constructor for class akka.actor.SuppressedDeadLetter$
-
- suspend() -
Method in interface akka.actor.Cell
- Recursively suspend this actor and all its children.
- suspend() -
Method in interface akka.actor.dungeon.Dispatch
-
- suspend() -
Method in class akka.actor.InternalActorRef
-
- suspend() -
Method in class akka.actor.LocalActorRef
- Suspends the actor so that it will not process messages until resumed.
- suspend() -
Method in interface akka.actor.MinimalActorRef
-
- suspend() -
Method in class akka.actor.RepointableActorRef
-
- suspend() -
Method in class akka.actor.UnstartedCell
-
- suspend() -
Method in class akka.dispatch.Mailbox
- Increment the suspend count by one.
- suspend(ActorCell) -
Method in class akka.dispatch.MessageDispatcher
- After the call to this method, the dispatcher mustn't begin any new message processing for the specified reference
- Suspend - Class in akka.dispatch.sysmsg
- INTERNAL API
- Suspend() -
Constructor for class akka.dispatch.sysmsg.Suspend
-
- suspend() -
Method in class akka.remote.RemoteActorRef
-
- suspend(ActorCell) -
Method in class akka.testkit.CallingThreadDispatcher
-
- suspend() -
Method in class akka.util.SerializedSuspendableExecutionContext
- Suspends execution of tasks until
resume is called,
this operation is idempotent.
- Suspend$ - Class in akka.dispatch.sysmsg
-
- Suspend$() -
Constructor for class akka.dispatch.sysmsg.Suspend$
-
- suspendChildren(Set<ActorRef>) -
Method in interface akka.actor.dungeon.Children
-
- suspendCount() -
Method in class akka.dispatch.Mailbox
-
- Suspended() -
Method in class akka.util.SerializedSuspendableExecutionContext$
-
- Suspended() -
Static method in class akka.util.SerializedSuspendableExecutionContext
-
- SuspendedState() -
Method in class akka.actor.ActorCell$
-
- SuspendedState() -
Static method in class akka.actor.ActorCell
-
- SuspendedWaitForChildrenState() -
Method in class akka.actor.ActorCell$
-
- SuspendedWaitForChildrenState() -
Static method in class akka.actor.ActorCell
-
- suspendMask() -
Method in class akka.dispatch.Mailbox$
-
- suspendMask() -
Static method in class akka.dispatch.Mailbox
-
- suspendNonRecursive() -
Method in interface akka.actor.dungeon.FaultHandling
-
- suspendReading(TcpConnection.ConnectionInfo) -
Method in class akka.io.TcpConnection
-
- suspendReading() -
Method in class akka.io.TcpMessage$
- Sending this command to the connection actor will disable reading from the TCP
socket.
- suspendReading() -
Static method in class akka.io.TcpMessage
- Sending this command to the connection actor will disable reading from the TCP
socket.
- suspendReading() -
Method in class akka.io.UdpConnectedMessage$
- Send this message to a listener actor (which sent a
Udp.Bound message) to
have it stop reading datagrams from the network.
- suspendReading() -
Static method in class akka.io.UdpConnectedMessage
- Send this message to a listener actor (which sent a
Udp.Bound message) to
have it stop reading datagrams from the network.
- suspendReading() -
Method in class akka.io.UdpMessage$
- Send this message to a listener actor (which sent a
Udp.Bound message) to
have it stop reading datagrams from the network.
- suspendReading() -
Static method in class akka.io.UdpMessage
- Send this message to a listener actor (which sent a
Udp.Bound message) to
have it stop reading datagrams from the network.
- suspendSwitch() -
Method in class akka.testkit.CallingThreadMailbox
-
- suspendUnit() -
Method in class akka.dispatch.Mailbox$
-
- suspendUnit() -
Static method in class akka.dispatch.Mailbox
-
- Swap - Class in akka.zeromq
- The
Swap option shall set the disk offload (swap) size for the specified socket. - Swap(long) -
Constructor for class akka.zeromq.Swap
-
- swap() -
Method in class akka.zeromq.ZeroMQ$
- The message to ask a ZeroMQ socket for its swap configuration.
- swap() -
Static method in class akka.zeromq.ZeroMQ
- The message to ask a ZeroMQ socket for its swap configuration.
- Swap$ - Class in akka.zeromq
- Gets the
Swap - Swap$() -
Constructor for class akka.zeromq.Swap$
-
- swapCell(Cell) -
Method in class akka.actor.RepointableActorRef
-
- swapChildrenRefs(ChildrenContainer, ChildrenContainer) -
Method in interface akka.actor.dungeon.Children
-
- swapLookup(Cell) -
Method in class akka.actor.RepointableActorRef
-
- swapMailbox(Mailbox) -
Method in interface akka.actor.dungeon.Dispatch
-
- Switch - Class in akka.util
- An atomic switch that can be either on or off
- Switch(boolean) -
Constructor for class akka.util.Switch
-
- Switch$ - Class in akka.util
-
- Switch$() -
Constructor for class akka.util.Switch$
-
- switchOff(Function0<BoxedUnit>) -
Method in class akka.util.Switch
- Executes the provided action if the lock is on under a lock, so be _very_ careful with longrunning/blocking operations in it
Only executes the action if the switch is on, and switches it off immediately after obtaining the lock
Will switch it back on if the provided action throws an exception
- switchOff() -
Method in class akka.util.Switch
- Switches the switch off (if on), uses locking
- switchOn(Function0<BoxedUnit>) -
Method in class akka.util.Switch
- Executes the provided action if the lock is off under a lock, so be _very_ careful with longrunning/blocking operations in it
Only executes the action if the switch is off, and switches it on immediately after obtaining the lock
Will switch it back off if the provided action throws an exception
- switchOn() -
Method in class akka.util.Switch
- Switches the switch on (if off), uses locking
- symmetricHash(TraversableOnce<T>, int) -
Method in class akka.routing.MurmurHash$
- Compute a hash that is symmetric in its arguments--that is,
where the order of appearance of elements does not matter.
- symmetricHash(TraversableOnce<T>, int) -
Static method in class akka.routing.MurmurHash
- Compute a hash that is symmetric in its arguments--that is,
where the order of appearance of elements does not matter.
- synchronousQueue(boolean) -
Method in class akka.dispatch.ThreadPoolConfig$
-
- synchronousQueue(boolean) -
Static method in class akka.dispatch.ThreadPoolConfig
-
- SyncJournal() -
Method in class akka.actor.mailbox.filebased.FileBasedMailboxSettings
-
- syncJournal() -
Method in class akka.actor.mailbox.filebased.filequeue.PersistentQueue$
-
- syncJournal() -
Method in class akka.actor.mailbox.filebased.filequeue.PersistentQueue
-
- SyncWriteJournal - Class in akka.persistence.journal.japi
- Java API: abstract journal, optimized for synchronous writes.
- SyncWriteJournal() -
Constructor for class akka.persistence.journal.japi.SyncWriteJournal
-
- SyncWriteJournal - Interface in akka.persistence.journal
- Abstract journal, optimized for synchronous writes.
- SysMsgAckTimeout() -
Method in class akka.remote.RemoteSettings
-
- SysMsgBufferSize() -
Method in class akka.remote.RemoteSettings
-
- SysResendLimit() -
Method in class akka.remote.RemoteSettings
-
- SysResendTimeout() -
Method in class akka.remote.RemoteSettings
-
- system() -
Method in class akka.actor.ActorCell
-
- system() -
Method in interface akka.actor.ActorContext
- The system that the actor belongs to.
- system() -
Method in class akka.actor.ActorDSL.Extension
-
- system() -
Method in class akka.actor.Address
-
- system() -
Method in interface akka.actor.Cell
- The system within which this Cell lives.
- system() -
Method in class akka.actor.mailbox.DurableMessageQueue
-
- system() -
Method in class akka.actor.RepointableActorRef
-
- system() -
Method in class akka.actor.TypedActorExtension
-
- system() -
Method in class akka.actor.UnstartedCell
-
- system() -
Method in interface akka.camel.Camel
- INTERNAL API
Returns the associated ActorSystem.
- system() -
Method in class akka.camel.internal.DefaultCamel
-
- system() -
Method in class akka.cluster.Cluster
-
- system() -
Method in class akka.cluster.protobuf.ClusterMessageSerializer
-
- system() -
Method in class akka.cluster.routing.AdaptiveLoadBalancingRoutingLogic
-
- system() -
Method in class akka.contrib.mailbox.PeekMailboxExtension
-
- system() -
Method in class akka.contrib.pattern.protobuf.DistributedPubSubMessageSerializer
-
- system() -
Method in interface akka.persistence.journal.JournalSpec
-
- system() -
Method in class akka.persistence.Persistence
-
- system() -
Method in class akka.persistence.serialization.MessageSerializer
-
- system() -
Method in interface akka.persistence.snapshot.SnapshotStoreSpec
-
- system() -
Method in class akka.remote.AddressUidExtension
-
- system() -
Method in class akka.remote.RemoteTransport
-
- system() -
Method in class akka.remote.serialization.DaemonMsgCreateSerializer
-
- system() -
Method in class akka.remote.serialization.MessageContainerSerializer
-
- system() -
Method in class akka.remote.testconductor.TestConductorExt
-
- system() -
Method in class akka.remote.transport.netty.NettyTransport
-
- system() -
Method in class akka.routing.ConsistentHashingRoutingLogic
-
- system() -
Method in class akka.serialization.JavaSerializer
-
- system() -
Method in class akka.serialization.Serialization.Information
-
- system() -
Method in class akka.serialization.Serialization
-
- system() -
Method in class akka.testkit.CallingThreadMailbox
-
- system() -
Method in class akka.testkit.DefaultTimeoutSpec
-
- system() -
Method in class akka.testkit.ImplicitSenderSpec
-
- system() -
Method in class akka.testkit.TestKit
-
- system() -
Method in interface akka.testkit.TestKitBase
-
- SYSTEM_FIELD_NUMBER -
Static variable in class akka.cluster.protobuf.msg.ClusterMessages.Address
-
- SYSTEM_FIELD_NUMBER -
Static variable in class akka.contrib.pattern.protobuf.msg.DistributedPubSubMessages.Address
-
- SYSTEM_FIELD_NUMBER -
Static variable in class akka.remote.testconductor.TestConductorProtocol.Address
-
- SYSTEM_FIELD_NUMBER -
Static variable in class akka.remote.WireFormats.AddressData
-
- systemActorOf(Props, String) -
Method in class akka.actor.ActorSystemImpl
-
- systemActorOf(Props, String) -
Method in class akka.actor.ExtendedActorSystem
- Create an actor in the "/system" namespace.
- systemDispatch(ActorCell, SystemMessage) -
Method in class akka.dispatch.Dispatcher
- INTERNAL API
- systemDispatch(ActorCell, SystemMessage) -
Method in class akka.dispatch.MessageDispatcher
- Will be called when the dispatcher is to queue an invocation for execution
- systemDispatch(ActorCell, SystemMessage) -
Method in class akka.testkit.CallingThreadDispatcher
-
- systemDrain(LatestFirstSystemMessageList) -
Method in interface akka.dispatch.DefaultSystemMessageQueue
-
- systemDrain(LatestFirstSystemMessageList) -
Method in interface akka.dispatch.SystemMessageQueue
- Dequeue all messages from system queue and return them as single-linked list.
- systemEnqueue(ActorRef, SystemMessage) -
Method in interface akka.dispatch.DefaultSystemMessageQueue
-
- systemEnqueue(ActorRef, SystemMessage) -
Method in interface akka.dispatch.SystemMessageQueue
- Enqueue a new system message, e.g.
- systemGuardian() -
Method in interface akka.actor.ActorRefProvider
- Reference to the supervisor used for all top-level system actors.
- systemGuardian() -
Method in class akka.actor.ActorSystemImpl
-
- systemGuardian() -
Method in class akka.actor.ExtendedActorSystem
- The top-level supervisor of all system-internal services like logging.
- systemGuardian() -
Method in class akka.actor.LocalActorRefProvider
-
- SystemGuardian - Class in akka.actor
- INTERNAL API
- SystemGuardian() -
Constructor for class akka.actor.SystemGuardian
-
- systemGuardian() -
Method in class akka.remote.RemoteActorRefProvider
-
- SystemGuardian$ - Class in akka.actor
- INTERNAL API
- SystemGuardian$() -
Constructor for class akka.actor.SystemGuardian$
-
- SystemGuardian.RegisterTerminationHook$ - Class in akka.actor
- For the purpose of orderly shutdown it's possible
to register interest in the termination of systemGuardian
and receive a notification
akka.actor.Guardian.TerminationHook
before systemGuardian is stopped. - SystemGuardian.RegisterTerminationHook$() -
Constructor for class akka.actor.SystemGuardian.RegisterTerminationHook$
-
- SystemGuardian.TerminationHook$ - Class in akka.actor
-
- SystemGuardian.TerminationHook$() -
Constructor for class akka.actor.SystemGuardian.TerminationHook$
-
- SystemGuardian.TerminationHookDone$ - Class in akka.actor
-
- SystemGuardian.TerminationHookDone$() -
Constructor for class akka.actor.SystemGuardian.TerminationHookDone$
-
- systemGuardianStrategy() -
Method in class akka.actor.LocalActorRefProvider
- Overridable supervision strategy to be used by the “/user” guardian.
- SystemHome() -
Method in class akka.actor.ActorSystem$
-
- SystemHome() -
Static method in class akka.actor.ActorSystem
-
- systemImpl() -
Method in class akka.actor.ActorCell
-
- systemImpl() -
Method in interface akka.actor.ActorRefFactory
- INTERNAL API
- systemImpl() -
Method in class akka.actor.ActorSystemImpl
-
- systemImpl() -
Method in interface akka.actor.Cell
- The system internals where this Cell lives.
- systemImpl() -
Method in class akka.actor.UnstartedCell
-
- systemInvoke(SystemMessage) -
Method in class akka.actor.ActorCell
-
- systemLoadAverage() -
Method in class akka.cluster.JmxMetricsCollector
- JMX Returns the OS-specific average load on the CPUs in the system, for the past 1 minute.
- systemLoadAverage() -
Method in class akka.cluster.SigarMetricsCollector
- (SIGAR / JMX) Returns the OS-specific average load on the CPUs in the system, for the past 1 minute.
- SystemLoadAverage() -
Method in class akka.cluster.StandardMetrics$
-
- systemLoadAverage() -
Method in class akka.cluster.StandardMetrics.Cpu
-
- SystemLoadAverage() -
Static method in class akka.cluster.StandardMetrics
-
- SystemLoadAverageMetricsSelector - Class in akka.cluster.routing
- MetricsSelector that uses the system load average metrics.
- SystemLoadAverageMetricsSelector() -
Constructor for class akka.cluster.routing.SystemLoadAverageMetricsSelector
-
- SystemLoadAverageMetricsSelector$ - Class in akka.cluster.routing
- MetricsSelector that uses the system load average metrics.
- SystemLoadAverageMetricsSelector$() -
Constructor for class akka.cluster.routing.SystemLoadAverageMetricsSelector$
-
- SystemMessage - Interface in akka.dispatch.sysmsg
- System messages are handled specially: they form their own queue within
each actor’s mailbox.
- SystemMessageList - Class in akka.dispatch.sysmsg
- INTERNAL API
- SystemMessageList() -
Constructor for class akka.dispatch.sysmsg.SystemMessageList
-
- SystemMessageList$ - Class in akka.dispatch.sysmsg
- INTERNAL API
- SystemMessageList$() -
Constructor for class akka.dispatch.sysmsg.SystemMessageList$
-
- SystemMessageQueue - Interface in akka.dispatch
- INTERNAL API
- systemName() -
Method in class akka.cluster.ClusterSettings
-
- systemName() -
Method in class akka.remote.RemoteActorRefProvider
-
- systemQueueGet() -
Method in class akka.dispatch.Mailbox
-
- systemQueuePut(LatestFirstSystemMessageList, LatestFirstSystemMessageList) -
Method in class akka.dispatch.Mailbox
-
- systemSettings() -
Method in interface akka.actor.mailbox.DurableMailboxSettings
- A reference to the enclosing actor system.
- systemSettings() -
Method in class akka.actor.mailbox.filebased.FileBasedMailboxSettings
-
interval and then send to a second, random picked, and so on till one full cycle..interval and then send to a second, random picked, and so on till one full cycle..interval and then send to a second, random picked, and so on till one full cycle.Abort command.TcpExt.manager() in order to bind to a listening socket.Tcp.Bind command will—in case of success—receive confirmation
in this form.Close command.ConfirmedClose command.TcpExt.manager().Tcp.Connect
command (for outbound) or to the handler for incoming connections designated
in the Tcp.Bind message.Tcp.WriteCommand and Tcp.Event.Tcp.WriteCommand can optionally request a positive acknowledgment to be sent
to the commanding actor.Tcp.NoAck instance which is used when no acknowledgment information is
explicitly provided.Tcp.Register message.Tcp.Connected message.SuspendReading
command in order to resume reading from the socket.useResumeWriting is in effect as was indicated in the Tcp.Register message
then this command needs to be sent to the connection actor in order to re-enable
writing after a Tcp.CommandFailed event.Tcp.Write and Tcp.WriteFile.Inet.SocketOption to enable or disable SO_KEEPALIVEInet.SocketOption to enable or disable OOBINLINE (receipt
of TCP urgent data) By default, this option is disabled and TCP urgent
data is silently discarded.Inet.SocketOption to enable or disable TCP_NODELAY
(disable or enable Nagle's algorithm)Tcp.Bound message).Unbind command will receive confirmation through this
message once the listening socket has been closed.Tcp.Write, Tcp.WriteFile and Tcp.CompoundWrite.count bytes starting at position from file at filePath to the connection.useResumeWriting is in effect as indicated in the Tcp.Register message,
the ResumeWriting command will be acknowledged by this message type, upon
which it is safe to send at least one write.Inet.SocketOption to enable or disable TCP_NODELAY
(disable or enable Nagle's algorithm)
Inet.SocketOption to enable or disable TCP_NODELAY
(disable or enable Nagle's algorithm)
Terminated = 2;
Terminated to non-watching testActor is not possible,
and therefore the Terminated message is wrapped.TestConductorExt extension:TestConductorExt extension:Conductor and
Player roles inside an Akka
Extension.AddressAddressAddressRequestAddressRequestBarrierOpDirectionEnterBarrierEnterBarrierFailTypeHelloHelloInjectFailureInjectFailureWrapperWrapperMute
to the TestEventListener to install a filter, and UnMute to
deinstall it.Mute
to the TestEventFilter to install a filter, and UnMute to
deinstall it.TestKit class: you may use
this if inheriting from a concrete class is not possible.blackhole, passThrough, and throttle you must
activate the failure injector and throttler transport adapters by
specifying testTransport(on = true) in your MultiNodeConfig.
TestTransport.TestTransport instances.Throttle = 1;
PersistentBatch, PersistentRepr and Deliver messages.
Snapshot.
ChannelSettings.
Inet.SocketOption to set the traffic class or
type-of-service octet in the IP header for packets sent from this
socket.
Inet.SocketOption to set the traffic class or
type-of-service octet in the IP header for packets sent from this
socket.
endpointUri.
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.TypedActor.MethodCall
to the provided ActorRef.
UdpExt.manager() in order to bind to the given
local port (or an automatically assigned one if the port number is zero).Udp.Bind command.Udp.Command and Udp.Event.Udp.Send can optionally request a positive acknowledgment to be sent
to the commanding actor.Udp.NoAck instance which is used when no acknowledgment information is
explicitly provided.Udp.Bind message using this message type.SuspendReading command.Udp.SimpleSender query to the UdpExt.manager() as well as by
the listener actors which are created in response to Udp.Bind.Udp.SimpleSender query.Inet.SocketOption to set the SO_BROADCAST optionUdp.Bound message) to
have it stop reading datagrams from the network.Udp.Bound
message in order to close the listening socket.Unbind command
after the socket has been closed.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.UdpConnected.Connect message when the UDP socket has been bound to the local and
remote addresses given.UdpConnected.Connected message) in order to close the socket.Disconnect message when the UDP socket has been closed.UdpConnected.Command and UdpConnected.Event.UdpConnected.Send can optionally request a positive acknowledgment to be sent
to the commanding actor.UdpConnected.NoAck instance which is used when no acknowledgment information is
explicitly provided.Udp.Bind message using this message type.SuspendReading command.Udp.Bound message) to
have it stop reading datagrams from the network.ConfirmablePersistent extractor.
ConfirmablePersistent extractor.
Persistent extractor.
Persistent extractor.
Tcp.Bound message).
Tcp.Bound message).
Udp.Bound
message in order to close the listening socket.
Udp.Bound
message in order to close the listening socket.
UnboundedStash trait is a version of Stash that enforces an unbounded stash for you actor.UntypedActor.onReceive(java.lang.Object) (e.g.
uid.PartialFunction that can be built during
runtime from Java.PartialFunction.Unreachable = 1;
Stash that does not enforce any mailbox type.subscribe registration.
Unsubscribe option shall remove an existing message filter
on a akka.zeromq.SocketType.Sub socket.Stash that enforces an unbounded deque for the actor.Stash that does not enforce any mailbox type.UntypedPersistentActor to send messages
with at-least-once delivery semantics to destinations.Persistent.Up = 1;
PersistentRepr.
PersistentView to update itself.true to assert that the
shutdown of the ActorSystem was done properly.
PersistentView.
Tcp.SimpleWriteCommand.ack() token not being a of type Tcp.NoAck.
AtLeastOnceDelivery.UnconfirmedWarning message
will be sent to self.
source, if given, applies a filter on the event’s origin
message applies a filter on the event’s message (either with String.startsWith or Regex.findFirstIn().isDefined)
If you want to match all Warning events, the most efficient is to use Left("").Terminated message
it will be propagated to user's receive.
preRestart action with the supplied function.
postRestart action with the supplied function.
preStart action with the supplied thunk.
postStop action with the supplied thunk.
AckAndEnvelopeContainerAckAndEnvelopeContainerAcknowledgementInfoAcknowledgementInfoActorRefDataActorRefDataAddressDataAddressDataAkkaControlMessageAkkaControlMessageAkkaHandshakeInfoAkkaHandshakeInfoAkkaProtocolMessageAkkaProtocolMessageCommandTypeDaemonMsgCreateDataDaemonMsgCreateDataDeployDataDeployDataPropsDataPropsDataRemoteEnvelopeRemoteEnvelopeSerializedMessageSerializedMessagebody converted to type T.
body converted to type clazz.
Deploy instances using this (i.e.
headers.
min and
max.
within(0 seconds, max)(f).
" in state " + label to each message it logs.
" in state " + label to each message it logs.
payload.
RoutingLogic.
uid.
ConsistentHash
Router to send messages to multiple destinations, Router in general
unwraps messages from DistributedPubSubMediator.Internal$.MediatorRouterEnvelope and sends the contents to Routees.
write(data, noAck()).
write(data, noAck()).
TestTransport.SwitchableLoggedBehavior for the write() method on handles.
count bytes starting at position from file at filePath to the connection.
count bytes starting at position from file at filePath to the connection.
ExtensionId and ExtensionIdProvider for the ZeroMQ module
|
|||||||||
| PREV NEXT | FRAMES NO FRAMES | ||||||||