public class RpcRegistry extends BucketStoreActor<RoutingTable>
It uses BucketStoreActor
to maintain this
cluster wide information.
Modifier and Type | Class and Description |
---|---|
static class |
RpcRegistry.Messages
All messages used by the RpcRegistry.
|
static class |
RpcRegistry.RemoteRpcEndpoint |
akka.persistence.Eventsourced.AsyncHandlerInvocation, akka.persistence.Eventsourced.AsyncHandlerInvocation$, akka.persistence.Eventsourced.PendingHandlerInvocation, akka.persistence.Eventsourced.ProcessingState, akka.persistence.Eventsourced.RecoveryTick, akka.persistence.Eventsourced.RecoveryTick$, akka.persistence.Eventsourced.StashingHandlerInvocation, akka.persistence.Eventsourced.StashingHandlerInvocation$, akka.persistence.Eventsourced.State
LOG
Constructor and Description |
---|
RpcRegistry(RemoteRpcProviderConfig config,
akka.actor.ActorRef rpcInvoker,
akka.actor.ActorRef rpcRegistrar) |
Modifier and Type | Method and Description |
---|---|
protected void |
handleCommand(Object message) |
protected void |
onBucketRemoved(akka.actor.Address address,
Bucket<RoutingTable> bucket)
Callback to subclasses invoked when a bucket is removed.
|
protected void |
onBucketsUpdated(Map<akka.actor.Address,Bucket<RoutingTable>> buckets)
Callback to subclasses invoked when the set of remote buckets is updated.
|
void |
postStop() |
static akka.actor.Props |
props(RemoteRpcProviderConfig config,
akka.actor.ActorRef rpcInvoker,
akka.actor.ActorRef rpcRegistrar)
Create a new props instance for instantiating an RpcRegistry actor.
|
getConfig, getLocalData, getRemoteBuckets, getVersions, handleRecover, isPersisting, persistenceId, preStart, updateLocalBucket
executeInSelf, ignoreMessage, onReceiveCommand, onReceiveRecover, unknownMessage
akka$actor$StashSupport$_setter_$akka$actor$StashSupport$$capacity_$eq, akka$actor$StashSupport$_setter_$mailbox_$eq, akka$actor$StashSupport$$capacity, akka$actor$StashSupport$$theStash_$eq, akka$actor$StashSupport$$theStash, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$extension_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$instanceId_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$internalStash_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$maxMessageBatchSize_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$pendingInvocations_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$persistingEvents_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$processingCommands_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$unstashFilterPredicate_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$writerUuid_$eq, akka$persistence$Eventsourced$$_lastSequenceNr_$eq, akka$persistence$Eventsourced$$_lastSequenceNr, akka$persistence$Eventsourced$$currentState_$eq, akka$persistence$Eventsourced$$currentState, akka$persistence$Eventsourced$$eventBatch_$eq, akka$persistence$Eventsourced$$eventBatch, akka$persistence$Eventsourced$$extension, akka$persistence$Eventsourced$$instanceId, akka$persistence$Eventsourced$$internalStash, akka$persistence$Eventsourced$$journalBatch_$eq, akka$persistence$Eventsourced$$journalBatch, akka$persistence$Eventsourced$$maxMessageBatchSize, akka$persistence$Eventsourced$$pendingInvocations, akka$persistence$Eventsourced$$pendingStashingPersistInvocations_$eq, akka$persistence$Eventsourced$$pendingStashingPersistInvocations, akka$persistence$Eventsourced$$persistingEvents, akka$persistence$Eventsourced$$processingCommands, akka$persistence$Eventsourced$$sequenceNr_$eq, akka$persistence$Eventsourced$$sequenceNr, akka$persistence$Eventsourced$$unstashFilterPredicate, akka$persistence$Eventsourced$$writeInProgress_$eq, akka$persistence$Eventsourced$$writeInProgress, akka$persistence$Eventsourced$$writerUuid, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, clearStash, createStash, deferAsync, deleteMessages, deleteSnapshot, deleteSnapshots, internalDeferAsync, internalPersist, internalPersistAll, internalPersistAllAsync, internalPersistAsync, internalStashOverflowStrategy, journal, journalPluginId, lastSequenceNr, loadSnapshot, mailbox, onPersistFailure, onPersistRejected, onReceive, onRecoveryFailure, onReplaySuccess, persist, persistAll, persistAllAsync, persistAsync, prepend, preRestart, receiveCommand, receiveRecover, recovery, recoveryFinished, recoveryRunning, saveSnapshot, snapshotPluginId, snapshotSequenceNr, snapshotStore, snapshotterId, stash, unhandled, unstash, unstashAll, unstashAll
akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, context, getContext, getSelf, getSender, postRestart, receive, self, sender, supervisorStrategy
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
$init$, akka$persistence$Eventsourced$$changeState, akka$persistence$Eventsourced$$flushBatch, akka$persistence$Eventsourced$$flushJournalBatch, akka$persistence$Eventsourced$$peekApplyHandler, akka$persistence$Eventsourced$$recovering, akka$persistence$Eventsourced$$setLastSequenceNr, akka$persistence$Eventsourced$$startRecovery, akka$persistence$Eventsourced$$stashInternally, akka$persistence$Eventsourced$$unstashInternally, akka$persistence$Eventsourced$$updateLastSequenceNr
public RpcRegistry(RemoteRpcProviderConfig config, akka.actor.ActorRef rpcInvoker, akka.actor.ActorRef rpcRegistrar)
public static akka.actor.Props props(RemoteRpcProviderConfig config, akka.actor.ActorRef rpcInvoker, akka.actor.ActorRef rpcRegistrar)
config
- Provider configurationrpcRegistrar
- Local RPC provider interface, used to register routers to remote nodesrpcInvoker
- Actor handling RPC invocation requests from remote nodesProps
instancepublic void postStop()
postStop
in interface akka.actor.Actor
postStop
in interface akka.actor.UnrestrictedStash
postStop
in class akka.persistence.UntypedPersistentActor
protected void handleCommand(Object message) throws Exception
handleCommand
in class BucketStoreActor<RoutingTable>
Exception
protected void onBucketRemoved(akka.actor.Address address, Bucket<RoutingTable> bucket)
BucketStoreActor
onBucketRemoved
in class BucketStoreActor<RoutingTable>
address
- Remote addressbucket
- Bucket removedprotected void onBucketsUpdated(Map<akka.actor.Address,Bucket<RoutingTable>> buckets)
BucketStoreActor
onBucketsUpdated
in class BucketStoreActor<RoutingTable>
buckets
- Map of address to new bucket. Never null, but can be empty.Copyright © 2019 OpenDaylight. All rights reserved.