RandomGroup
routing
RandomPool
routing
RandomRouter
routing
RandomRoutingLogic
routing
Rate
Throttler zeromq
RateInt
Throttler
ReachabilityEvent
ClusterEvent
ReachableMember
ClusterEvent
RealMessage
TestActor
Reason
FSM
Receive
Actor Direction
ReceiveBufferSize
SO SoForwarders NettyTransportSettings zeromq
ReceiveBuilder
pf
ReceiveHighWatermark
zeromq
ReceiveTimeout
actor
ReceiveWhile
JavaTestKit
Received
Tcp Udp UdpConnected
ReceivedMessageSizeLimit
Settings
Receiver
TypedActor ReliableProxy
ReconnectBackoff
Settings
ReconnectIVL
zeromq
ReconnectIVLMax
zeromq
Recover
dispatch persistence
RecoverBridge
japi
Recovery
persistence
RecoveryCompleted
persistence
RecoveryFailure
persistence
RecoveryInterval
zeromq
RedeliverFailure
persistence
ReduceGossipDifferentViewProbability
ClusterSettings
ReentrantGuard
util
ReflectiveDynamicAccess
actor
Register
Tcp
RegisterTimeout
Settings
RelativeActorPath
actor
ReliableProxy
pattern
RemoteLifecycleEventsLogLevel
RemoteSettings
RemoteRouterConfig
routing
RemoteScope
remote
RemoteSettings
remote
RemoteTransportException
remote
RemoteTransportExceptionNoStackTrace
remote
RemotingErrorEvent
remote
RemotingLifecycleEvent
remote
RemotingListenEvent
remote
RemotingShutdownEvent
remote
Remove
JournalItem DistributedPubSubMediator
RemoveRoutee
routing
RemoveTentative
JournalItem
Removed
MemberStatus
Rep
SocketType
ReplyTimeout
CamelSettings
Req
SocketType
Request
zeromq
RequiresMessageQueue
dispatch
Requiring
Helpers
ResendBufferCapacityReachedException
remote
ResendUnfulfillableException
remote
Reset
persistence
ResetException
persistence
Resizer
routing
Response
zeromq
Restart
SupervisorStrategy Act
Resume
SupervisorStrategy Act
ResumeAccepting
Tcp
ResumeReading
Tcp Udp UdpConnected
ResumeWriting
Tcp
RetryGateClosedFor
RemoteSettings
RetryUnsuccessfulJoinAfter
ClusterSettings
ReuseAddress
SO SoForwarders
RoleLeaderChanged
ClusterEvent
RoleName
testconductor
Roles
ClusterSettings
RootActorPath
actor
RoundRobinGroup
routing
RoundRobinPool
routing
RoundRobinRouter
routing
RoundRobinRoutingLogic
routing
Routee
routing
Routees
routing
Router
routing SocketType
RouterConfig
routing
RouterEnvelope
routing
RouterRoutees
routing
RoutingLogic
routing
rampup
DefaultResizer
rampupRate
DefaultResizer
random
Crypt
rate
SetRate TimerBasedThrottler ZeroMQ
rawValue
SeqNo
readHandlerPromise
AssociationHandle TestAssociationHandle
readJournalEntry
Journal
ready
ActorTransportAdapterManager TestLatch
reason
StopEvent ForceDisassociateExplicitly
rebalance
AbstractShardAllocationStrategy LeastShardAllocationStrategy ShardAllocationStrategy
rebalanceInProgress
ShardCoordinator
rebalanceTask
ShardCoordinator
receive
Terminator AbstractActor Actor FSM Inbox UntypedActor Act Inbox QueueCollection Producer JavaLogger Aggregator ClusterClient ClusterReceptionist ClusterSingletonProxy DistributedPubSubMediator Receiver ShardCoordinatorSupervisor ShardRegion DeadLetterListener DefaultLogger Slf4jLogger DefaultOSGiLogger AbstractPersistentActor Channel EventsourcedProcessor PersistentActor PersistentChannel AsyncWriteJournal SyncWriteJournal SharedLeveldbStore SnapshotStore AckedReceiveBuffer ActorTransportAdapterManager TestActor TestActorRef TestEventListener Transactor
receiveBufferSize
SoJavaFactories ZeroMQ
receiveClusterEvent
ShardRegion
receiveClusterState
ShardRegion
receiveCommand
ShardCoordinator ShardRegion UntypedPersistentActor
receiveCoordinatorMessage
ShardRegion
receiveHighWatermark
ZeroMQ
receiveN
JavaTestKit TestKitBase
receiveOne
JavaTestKit TestKitBase
receiveRecover
ShardCoordinator UntypedPersistentActor
receiveTerminated
ShardRegion
receiveTimeout
ActorContext
receiveWhile
TestKitBase
receiver
Inbox ReliableProxy
recipient
DeadLetter UnhandledMessage WriteAttempt
reconnectIVL
ZeroMQ
reconnectIVLMax
ZeroMQ
reconnectTimer
ReliableProxy
reconnecting
ReliableProxy
recover
Recover
recoveryInterval
ZeroMQ
redeliverFailureListener
ChannelSettings PersistentChannelSettings
redeliverInterval
AtLeastOnceDelivery ChannelSettings atLeastOnceDelivery PersistentChannelSettings
redeliverMax
ChannelSettings PersistentChannelSettings
redeliveries
ConfirmablePersistent PersistentRepr
reduce
Futures
ref
ActorIdentity Put Subscribe Unsubscribe TargetChanged Entry ActorRefRoutee UnWatch Watch TestProbe
refreshContactsTask
ClusterClient
regionByShard
ShardRegion
regions
ShardRegion
register
PeekMailboxExtension ShardRegion BalancingDispatcher MessageDispatcher PinnedDispatcher TcpMessage CallingThreadDispatcher
registerConfigurator
Dispatchers
registerExtension
ActorSystem
registerForExecution
Dispatcher MessageDispatcher CallingThreadDispatcher
registerListenerPair
AssociationRegistry
registerOnMemberUp
Cluster
registerOnTermination
ActorSystem
registerService
ClusterReceptionistExtension ActorSystemActivator
registerSubscriber
ClusterReceptionistExtension
registerTempActor
ActorRefProvider
registerTopic
DistributedPubSubMediator
registerTransport
AssociationRegistry
registrationMessage
ShardRegion
registry
DistributedPubSubMediator TestTransport
rejectedExecution
SaneRejectedExecutionHandler
rejectionPolicy
ThreadPoolConfig
release
BufferPool
remaining
JavaTestKit TestKitBase
remainingCapacity
BoundedBlockingQueue
remainingDuration
CircuitBreakerOpenException
remainingOr
JavaTestKit TestKitBase
remote
akka DisassociateAttempt
remoteAddress
Connect Connected Connect AssociatedEvent AssociationErrorEvent AssociationEvent DisassociatedEvent AbstractTransportAdapterHandle AssociateUnderlying AssociationHandle TestAssociationHandle AssociateAttempt
remoteListenerRelativeTo
AssociationRegistry
remove
FileBasedMessageQueue Journal PersistentQueue QueueCollection ClusterSingletonProxy WorkList DefaultFailureDetectorRegistry FailureDetectorRegistry ConsistentHash BoundedBlockingQueue Index
removeAll
WorkList BoundedBlockingQueue
removeFilter
TestEventListener
removeNode
Conductor
removeRoutee
Router
removeScheme
SchemeAugmenter
removeTentative
Journal
removeValue
Index
removed
MemberStatus ClusterSingletonManager
removedTimeToLiveMillis
DistributedPubSubMediator
replay
Journal
replayJournal
PersistentQueue
replayMax
Recover Update
replies
State
reply
JavaTestKit TestProbe
replyPersistent
PersistentChannelSettings
replyTimeout
Consumer
replying
State
reportFailure
MessageDispatcher
requestRestartPermission
ChildRestartStats
requestShardBufferHomes
ShardRegion
requester
DisassociateAttempt
requiring
Requiring
resend
ReliableProxy
resendTimer
ReliableProxy
reset
DefaultFailureDetectorRegistry FailureDetectorRegistry AssociationRegistry TestBarrier TestLatch
resetBackoff
ReliableProxy
resetStreamCache
CamelMessage
resize
DefaultResizer Resizer
resizer
AdaptiveLoadBalancingPool AdaptiveLoadBalancingRouter ClusterRouterConfig ClusterRouterPool RemoteRouterConfig BalancingPool BroadcastPool BroadcastRouter ConsistentHashingPool ConsistentHashingRouter FromConfig Pool RandomPool RandomRouter RoundRobinPool RoundRobinRouter ScatterGatherFirstCompletedPool ScatterGatherFirstCompletedRouter SmallestMailboxPool SmallestMailboxRouter
resolveActorRef
ActorRefProvider
resolveClass
ClassLoaderObjectInputStream
resolveOne
ActorSelection
responseTunnel
ClusterReceptionist
restart
SupervisorStrategy
restartChild
SupervisorStrategy
restartTimeWindowStartNanos
ChildRestartStats
result
TestLatch ByteStringBuilder
resume
SupervisorStrategy MessageDispatcher CallingThreadDispatcher
resumeAccepting
TcpMessage
resumeChild
SupervisorStrategy
resumeReading
TcpMessage UdpConnectedMessage UdpMessage
resumeReads
PersistentQueue
resumeWriting
TcpMessage
retainAll
BoundedBlockingQueue
retryGateClosedFor
ReliableProxy
retryTask
ShardRegion
returnsFuture
MethodCall
returnsJOption
MethodCall
returnsOption
MethodCall
reusableQueue
ThreadPoolConfig
reuseAddress
SoJavaFactories
role
RoleLeaderChanged MultiNodeConfig
roleLeader
CurrentClusterState
roleLeaderMap
CurrentClusterState
roles
Member MultiNodeSpec
roll
Journal
root
ActorPath ChildActorPath RootActorPath Logger
rootGuardian
ActorRefProvider
rootGuardianAt
ActorRefProvider
rootPath
ActorRefProvider
route
Router
routeResponse
ProducerSupport UntypedProducerActor
routee
AddRoutee RemoveRoutee
routees
AdaptiveLoadBalancingRouter BroadcastRouter ConsistentHashingRouter RandomRouter RoundRobinRouter Routees Router RouterRoutees ScatterGatherFirstCompletedRouter SeveralRoutees SmallestMailboxRouter
routeesPath
ClusterRouterSettings
routeesPaths
ClusterRouterGroupSettings
routerConfig
Deploy Props
routerDispatcher
AdaptiveLoadBalancingGroup AdaptiveLoadBalancingPool AdaptiveLoadBalancingRouter RemoteRouterConfig BalancingPool BroadcastGroup BroadcastPool BroadcastRouter ConsistentHashingGroup ConsistentHashingPool ConsistentHashingRouter CustomRouterConfig FromConfig NoRouter RandomGroup RandomPool RandomRouter RoundRobinGroup RoundRobinPool RoundRobinRouter RouterConfig ScatterGatherFirstCompletedGroup ScatterGatherFirstCompletedPool ScatterGatherFirstCompletedRouter SmallestMailboxPool SmallestMailboxRouter
routing
cluster remote akka
routingLogicController
AdaptiveLoadBalancingGroup AdaptiveLoadBalancingPool AdaptiveLoadBalancingRouter RouterConfig
run
TaskHolder TaskInvocation EventFilter Within AutoPilot KeepRunning NoAutoPilot
runOn
MultiNodeSpec
runnable
TaskInvocation