RandomGroup
routing
RandomPool
routing
RandomRoutingLogic
routing
Rate
Throttler
RateExceededException
stream
RateInt
Throttler
ReachabilityEvent
ClusterEvent
ReachableMember
ClusterEvent
ReadAll
Replicator
ReadConsistency
Replicator
ReadEventAdapter
journal
ReadFrom
Replicator
ReadJournal
javadsl scaladsl
ReadJournalProvider
query
ReadLocal
Replicator
ReadMajority
Replicator
ReadManifest
ReplicatorMessageSerializer
ReadResultManifest
ReplicatorMessageSerializer
RealMessage
TestActor
Reason
FSM PersistentFSM
Receive
Actor Direction StageActorRef
ReceiveBufferSize
SO SoForwarders NettyTransportSettings
ReceiveBuilder
pf
ReceivePipeline
pattern
ReceiveTimeout
actor Receiver
ReceiveTimeoutSet
Effect
ReceiveWhile
JavaTestKit
Received
Tcp Udp UdpConnected FlowMonitorState
ReceivedMessageSizeLimit
Settings
Receiver
TypedActor ReliableProxy patterns
Receptionist
patterns
ReconnectBackoff
Settings
Recover
dispatch fusing
RecoverBridge
japi
RecoverWith
fusing
Recovery
persistence
RecoveryCompleted
persistence
RecoveryTimedOut
persistence
Reduce
fusing
ReduceGossipDifferentViewProbability
ClusterSettings
ReentrantGuard
util
ReflectiveDynamicAccess
actor
Register
Tcp Receptionist
RegisterTimeout
Settings
Registered
Receptionist
RelativeActorPath
actor
ReliableProxy
pattern
Remote
ProviderSelection
RemoteInstrument
artery
RemoteLifecycleEventsLogLevel
RemoteSettings
RemoteRouterConfig
routing
RemoteScope
remote
RemoteSettings
remote
RemoteTransportException
remote
RemoteTransportExceptionNoStackTrace
remote
RemotingErrorEvent
remote
RemotingLifecycleEvent
remote
RemotingListenEvent
remote
RemotingShutdownEvent
remote
Remove
DistributedPubSubMediator
RemoveInternalClusterShardingData
sharding
RemoveRoutee
routing
Removed
MemberStatus
RemovedNodePruning
ddata
ReplicaCount
Replicator
ReplicatedData
ddata
ReplicatedDataMessages
msg
ReplicatedDataSerialization
ddata
ReplicatedDataSerializer
protobuf
ReplicationDeleteFailure
Replicator
Replicator
ddata
ReplicatorMessage
Replicator
ReplicatorMessageSerializer
protobuf
ReplicatorMessages
msg
ReplicatorSettings
ddata
Replies
Receiver
ReplyTimeout
CamelSettings
ReplyToStrategy
persistence
Repr
Flow FlowOps FlowOpsMat PortOps Source SubFlow
ReprMat
Flow FlowOpsMat Source
Request
ActorPublisherMessage
RequestMore
ActorGraphInterpreter TestPublisher
RequestOne
SubSink
RequestStrategy
actor
Requested
QueueSink
RequiresMessageQueue
dispatch
Requiring
Helpers
ResendBufferCapacityReachedException
remote
ResendUnfulfillableException
remote
Reset
BackoffSupervisor
ResetCounter
JournalPerfSpec
Resizer
routing
ResizerInitializationException
routing
Resolve
Dns
Resolved
Dns
Resolver
Settings
ResolverConfig
Settings
Restart
SupervisorStrategy Act Supervision Failed
RestartCount
BackoffSupervisor
Restarter
patterns
Result
LineNumbers
Resume
SupervisorStrategy Act Supervision ActorGraphInterpreter Failed
ResumeAccepting
Tcp
ResumeReading
Tcp Udp UdpConnected
ResumeWriting
Tcp
RetryGateClosedFor
RemoteSettings
RetryUnsuccessfulJoinAfter
ClusterSettings
ReuseAddress
SO SoForwarders
ReverseCombinerBase
Implicits
ReverseOps
Builder
ReversePortOps
Implicits
RoleLeaderChanged
ClusterEvent
RoleName
testconductor
Roles
ClusterSettings
RootActorPath
actor
RoundRobinGroup
routing
RoundRobinPool
routing
RoundRobinRoutingLogic
routing
Routee
routing
Routees
routing
Router
routing
RouterConfig
routing
RouterEnvelope
routing
RoutingLogic
routing
RunnableGraph
javadsl scaladsl
rampup
DefaultResizer
rampupRate
DefaultResizer
random
Crypt
range
Source
rate
SetRate TimerBasedThrottler
rawValue
SeqNo
read
GraphStageLogic
readHandlerPromise
AssociationHandle TestAssociationHandle
readJournalFor
PersistenceQuery
readLocal
Replicator
readN
GraphStageLogic
ready
ActorTransportAdapterManager TestLatch
reason
StopEvent StopEvent ForceDisassociateExplicitly
rebalance
AbstractShardAllocationStrategy LeastShardAllocationStrategy ShardAllocationStrategy
rebalanceInProgress
ShardCoordinator
rebalanceInterval
TuningParameters
rebalanceTask
ShardCoordinator
receive
Terminator AbstractActor Actor FSM Inbox UntypedActor Act Inbox Producer ClusterClient ClusterReceptionist LmdbDurableStore Replicator DistributedPubSubMediator DDataShardCoordinator RemoveInternalClusterShardingData ShardRegion ClusterSingletonProxy JavaLogger Aggregator Receiver ActorClassificationUnsubscriber DeadLetterListener EventStreamUnsubscriber DefaultLogger Slf4jLogger InetAddressDnsResolver SimpleDnsManager DefaultOSGiLogger BackoffSupervisor AbstractPersistentActor PersistentActor PersistentFSMBase AsyncWriteJournal PersistencePluginProxy SharedLeveldbStore SnapshotStore AckedReceiveBuffer ActorTransportAdapterManager FanIn FanOut StreamSupervisor ActorGraphInterpreter GraphInterpreterShell TestActor TestActorRef BlackholeActor EchoActor ForwardActor TestEventListener
receiveAll
Inbox
receiveBufferSize
SoJavaFactories
receiveClockTick
Replicator
receiveClusterEvent
ShardRegion
receiveClusterState
ShardRegion
receiveCommand
PersistentShardCoordinator ShardRegion UntypedPersistentActor PersistentFSM BenchActor
receiveCoordinatorMessage
ShardRegion
receiveDelete
Replicator
receiveFlushChanges
Replicator
receiveGet
Replicator
receiveGetKeyIds
Replicator
receiveGetReplicaCount
Replicator
receiveGossip
Replicator
receiveGossipTick
Replicator
receiveLeaderChanged
Replicator
receiveMemberRemoved
Replicator
receiveMemberUp
Replicator
receiveMsg
Inbox
receiveN
JavaTestKit TestKitBase
receiveOne
JavaTestKit TestKitBase
receivePluginInternal
AsyncWriteJournal SnapshotStore
receiveQuery
ShardRegion
receiveReachable
Replicator
receiveRead
Replicator
receiveReadRepair
Replicator
receiveRecover
PersistentShardCoordinator UntypedPersistentActor PersistentFSM BenchActor
receiveRemovedNodePruningTick
Replicator
receiveSnapshotResult
PersistentShardCoordinator
receiveSnapshotStore
SnapshotStore
receiveStatus
Replicator
receiveSubscribe
Replicator
receiveTerminated
Replicator ShardCoordinator ShardRegion
receiveTimeout
ActorContext
receiveUnreachable
Replicator
receiveUnsubscribe
Replicator
receiveUpdate
Replicator
receiveWeaklyUpMemberUp
Replicator
receiveWhile
ManualProbe ManualProbe TestKitBase
receiveWithin
ManualProbe
receiveWrite
Replicator
receiveWriteJournal
AsyncWriteJournal
received
FlowMonitorState
receiver
Inbox ReliableProxy GetAllResult GetOneResult
recipient
AllDeadLetters DeadLetter SuppressedDeadLetter UnhandledMessage WriteAttempt Dropped
reconnectTimeout
ClusterClientSettings
reconnectTimer
ReliableProxy
reconnecting
ReliableProxy
recover
Recover DefaultAttributes Flow Source SubFlow SubSource FlowOps
recoverEntities
AllAtOnceEntityRecoveryStrategy ConstantRateEntityRecoveryStrategy EntityRecoveryStrategy
recoverWith
DefaultAttributes Flow Source SubFlow SubSource FlowOps
recoverWithRetries
Flow Source SubFlow SubSource FlowOps
recovery
PersistenceRecovery PersistentView
redeliverInterval
AtLeastOnceDeliveryLike atLeastOnceDelivery
redeliveryBurstLimit
AtLeastOnceDeliveryLike atLeastOnceDelivery
reduce
Futures DefaultAttributes Flow Sink Source SubFlow SubSource FlowOps Sink
ref
ActorIdentity Put Subscribe Unsubscribe TargetChanged Entry CurrentChild FutureRef PromiseRef ActorRefRoutee StageActor UnWatch Watch TestProbe Askable DeathPactException Inbox Terminated
refreshContactsInterval
ClusterClientSettings
refreshContactsTask
ClusterClient
regionByShard
ShardRegion
regionProxyTerminated
ShardCoordinator
regionTerminated
ShardCoordinator
regionTerminationInProgress
ShardCoordinator
regions
ShardRegion ClusterShardingStats CurrentRegions
register
ShardRegion PeekMailboxExtension BalancingDispatcher MessageDispatcher PinnedDispatcher TcpMessage CallingThreadDispatcher
registerConfigurator
Dispatchers
registerExtension
ActorSystem
registerForExecution
Dispatcher MessageDispatcher CallingThreadDispatcher
registerListenerPair
AssociationRegistry
registerOnMemberRemoved
Cluster
registerOnMemberUp
Cluster
registerOnTermination
ActorSystem
registerService
ClusterClientReceptionist ActorSystemActivator
registerShell
ActorGraphInterpreter
registerSrc
MaterializerSession
registerSubscriber
ClusterClientReceptionist
registerTempActor
ActorRefProvider
registerTopic
DistributedPubSubMediator
registerTransport
AssociationRegistry
registrationMessage
ShardRegion
registry
DistributedPubSubMediator TestTransport
rejectedExecution
SaneRejectedExecutionHandler
rejectionPolicy
ThreadPoolConfig
relativeError
CountMinSketch
release
BufferPool
remaining
JavaTestKit TestKitBase
remainingCapacity
BoundedBlockingQueue
remainingDuration
CircuitBreakerOpenException
remainingOr
JavaTestKit TestKitBase
remainingOrDefault
JavaTestKit TestKitBase
remainingPids
RemoveInternalClusterShardingData
remainingRequested
ActorSubscriber
rememberEntities
ClusterShardingSettings
remote
ProviderSelection akka DisassociateAttempt
remoteAddress
Connect Connected Connect AssociatedEvent AssociationErrorEvent AssociationEvent DisassociatedEvent ThisActorSystemQuarantinedEvent AbstractTransportAdapterHandle AssociateUnderlying AssociationHandle TestAssociationHandle AssociateAttempt IncomingConnection OutgoingConnection IncomingConnection OutgoingConnection
remoteListenerRelativeTo
AssociationRegistry
remoteMessageReceived
RemoteInstrument
remoteMessageSent
RemoteInstrument
remotePathOf
Cluster
remoteReadMetadata
RemoteInstrument
remoteWriteMetadata
RemoteInstrument
removalMargin
ShardCoordinator ClusterSingletonManager ClusterSingletonManagerSettings
remove
LWWMap ORMap ORMultiMap ORSet PNCounterMap RemoveInternalClusterShardingData ClusterSingletonProxy WorkList DefaultFailureDetectorRegistry FailureDetectorRegistry ConsistentHash BoundedBlockingQueue Index
removeAll
WorkList BoundedBlockingQueue
removeBinding
ORMultiMap
removeFilter
TestEventListener
removeInbox
StubbedActorContext
removeNext
RemoveInternalClusterShardingData
removeNode
Conductor
removeRoutee
Router
removeScheme
SchemeAugmenter
removeValue
Index
removed
MemberStatus ClusterSingletonManager TypedMultiMap
removedNodes
Replicator
removedTimeToLive
DistributedPubSubSettings
removedTimeToLiveMillis
DistributedPubSubMediator
repeat
DefaultAttributes Source Source
replaceBinding
ORMultiMap
replaceShape
ProcessorModule SinkModule SourceModule CompositeModule CopiedModule EmptyModule FusedModule Module StructuralInfoModule GraphModule GraphStageModule
replacement
SnapshotSerializer
replayMax
Recovery Update
replayedMessage
JournalSpec
replica
Replicator
replicator
DistributedData
replies
State State
reply
Store JavaTestKit TestProbe
replyTimeout
Consumer
replyTo
StoreReply Initialize CreateSystemActor ExternalAddress GetAll GetOne Find Register
replyToRegionStateQuery
ShardRegion
replyToRegionStatsQuery
ShardRegion
replying
State State
reportFailure
MessageDispatcher
reportMessageCount
DefaultOptimalSizeExploringResizer OptimalSizeExploringResizer
request
Get GetFailure GetResponse GetSuccess ModifyFailure NotFound StoreFailure Update UpdateResponse UpdateSuccess UpdateTimeout ActorSubscriber SubstreamSubscription BoundarySubscription Probe
requestDemand
MaxInFlightRequestStrategy OneByOneRequestStrategy RequestStrategy WatermarkRequestStrategy ZeroRequestStrategy
requestNext
Probe
requestRestartPermission
ChildRestartStats
requestShardBufferHomes
ShardRegion
requestStrategy
ActorSubscriber
requester
DisassociateAttempt
requireSamePortsAndShapeAs
Shape
requireSamePortsAs
Shape
requiring
Requiring
resend
ReliableProxy
resendTimer
ReliableProxy
reset
BackoffSupervisor DefaultFailureDetectorRegistry FailureDetectorRegistry AssociationRegistry TestBarrier TestLatch
resetBackoff
ReliableProxy
resetStreamCache
CamelMessage
resetTimeout
CircuitBreakerPropsBuilder
resize
DefaultOptimalSizeExploringResizer DefaultResizer Resizer
resizer
AdaptiveLoadBalancingPool AdaptiveLoadBalancingPool ClusterRouterPool RemoteRouterConfig BalancingPool BroadcastPool ConsistentHashingPool FromConfig Pool RandomPool RoundRobinPool ScatterGatherFirstCompletedPool SmallestMailboxPool TailChoppingPool
resolve
Dns
resolveActorRef
ActorRefProvider SerializationSupport
resolveClass
ClassLoaderObjectInputStream
resolveOne
ActorSelection
resolveOneCS
ActorSelection
response
ReplyToStrategy
responseTunnel
ClusterReceptionist
responseTunnelReceiveTimeout
ClusterReceptionistSettings
restart
SupervisorStrategy Supervision AbstractStage
restartChild
SupervisorStrategy
restartTimeWindowStartNanos
ChildRestartStats
restartingDecider
Supervision
resubmitOnBlock
MessageDispatcher
result
TestLatch ByteStringBuilder
resume
SupervisorStrategy MessageDispatcher Supervision CallingThreadDispatcher Restarter
resumeAccepting
TcpMessage
resumeChild
SupervisorStrategy
resumeReading
TcpMessage UdpConnectedMessage UdpMessage
resumeWriting
TcpMessage
resumingDecider
Supervision
retainAll
BoundedBlockingQueue
retryCount
ShardRegion
retryGateClosedFor
ReliableProxy
retryInterval
TuningParameters
retryTask
ShardRegion
returnsFuture
MethodCall
returnsJOption
MethodCall
returnsOption
MethodCall
reusableQueue
ThreadPoolConfig
reuseAddress
SoJavaFactories
reverseClock
LWWRegister
reversed
BidiShape BidiFlow BidiFlow
right
Keep Keep And Or
role
RoleLeaderChanged ClusterReceptionistSettings ReplicatorSettings DistributedPubSubSettings ClusterShardingSettings ClusterSingletonManagerSettings ClusterSingletonProxySettings MultiNodeConfig
roleLeader
CurrentClusterState
roleLeaderMap
CurrentClusterState
roles
Member MultiNodeSpec
root
ActorPath ChildActorPath RootActorPath Logger
rootGuardian
ActorRefProvider
rootGuardianAt
ActorRefProvider
rootPath
ActorRefProvider
route
Router
routeResponse
ProducerSupport UntypedProducerActor
routee
AddRoutee RemoveRoutee
routees
Routees Router SeveralRoutees
routeesPaths
ClusterRouterGroupSettings
routerConfig
Deploy Props
routerDispatcher
AdaptiveLoadBalancingGroup AdaptiveLoadBalancingPool AdaptiveLoadBalancingGroup AdaptiveLoadBalancingPool RemoteRouterConfig BalancingPool BroadcastGroup BroadcastPool ConsistentHashingGroup ConsistentHashingPool CustomRouterConfig FromConfig NoRouter RandomGroup RandomPool RoundRobinGroup RoundRobinPool RouterConfig ScatterGatherFirstCompletedGroup ScatterGatherFirstCompletedPool SmallestMailboxPool TailChoppingGroup TailChoppingPool
routing
cluster remote akka
routingLogic
DistributedPubSubSettings
routingLogicController
AdaptiveLoadBalancingGroup AdaptiveLoadBalancingPool AdaptiveLoadBalancingGroup AdaptiveLoadBalancingPool RouterConfig
run
TaskHolder TaskInvocation RunnableGraph RunnableGraph EventFilter Within AutoPilot KeepRunning NoAutoPilot EffectfulActorContext
runAsyncInput
GraphInterpreter
runBatch
GraphInterpreterShell
runFold
Source Source
runFoldAsync
Source Source
runForeach
Source Source
runOn
MultiNodeSpec
runReduce
Source Source
runWith
Flow Sink Source Flow Sink Source
runnable
TaskInvocation