org.opendaylight.controller.remote.rpc.registry

Class RpcRegistry

java.lang.Object

akka.actor.UntypedActor

akka.persistence.UntypedPersistentActor

org.opendaylight.controller.cluster.common.actor.AbstractUntypedPersistentActor

org.opendaylight.controller.cluster.common.actor.AbstractUntypedPersistentActorWithMetering

org.opendaylight.controller.remote.rpc.registry.gossip.BucketStoreActor<RoutingTable>

org.opendaylight.controller.remote.rpc.registry.RpcRegistry

All Implemented Interfaces:

akka.actor.Actor, akka.actor.Stash, akka.actor.StashFactory, akka.actor.StashSupport, akka.actor.UnrestrictedStash, akka.dispatch.RequiresMessageQueue<akka.dispatch.DequeBasedMessageQueueSemantics>, akka.persistence.Eventsourced, akka.persistence.PersistenceIdentity, akka.persistence.PersistenceRecovery, akka.persistence.PersistenceStash, akka.persistence.Snapshotter, ExecuteInSelfActor

public class RpcRegistry
extends BucketStoreActor<RoutingTable>

Registry to look up cluster nodes that have registered for a given RPC.

It uses BucketStoreActor to maintain this cluster wide information.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RpcRegistry.Messages All messages used by the RpcRegistry.
static class	RpcRegistry.RemoteRpcEndpoint

Nested classes/interfaces inherited from interface akka.persistence.Eventsourced

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

Nested classes/interfaces inherited from interface akka.actor.Actor

akka.actor.Actor.emptyBehavior$, akka.actor.Actor.ignoringBehavior$

Field Summary

Fields inherited from class org.opendaylight.controller.cluster.common.actor.AbstractUntypedPersistentActor

LOG

Constructor Summary

Constructors

Constructor and Description
RpcRegistry(RemoteRpcProviderConfig config, akka.actor.ActorRef rpcInvoker, akka.actor.ActorRef rpcRegistrar)

Method Summary

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.

Methods inherited from class org.opendaylight.controller.remote.rpc.registry.gossip.BucketStoreActor

getConfig, getLocalData, getRemoteBuckets, getVersions, handleRecover, isPersisting, persistenceId, preStart, updateLocalBucket

Methods inherited from class org.opendaylight.controller.cluster.common.actor.AbstractUntypedPersistentActor

executeInSelf, ignoreMessage, onReceiveCommand, onReceiveRecover, unknownMessage

Methods inherited from class akka.persistence.UntypedPersistentActor

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, defer, deferAsync, deleteMessages, deleteSnapshot, deleteSnapshots, internalDefer, internalDeferAsync, internalDeleteMessagesBeforeSnapshot, 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

Methods inherited from class akka.actor.UntypedActor

akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, context, getContext, getSelf, getSender, postRestart, receive, self, sender, supervisorStrategy

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface akka.persistence.Eventsourced

$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, akka$persistence$Eventsourced$$writeEventFailed, akka$persistence$Eventsourced$$writeEventRejected, akka$persistence$Eventsourced$$writeEventSucceeded

Methods inherited from interface akka.persistence.Snapshotter

$init$

Methods inherited from interface akka.persistence.PersistenceStash

$init$

Methods inherited from interface akka.actor.UnrestrictedStash

$init$

Methods inherited from interface akka.actor.Actor

$init$, akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, context, noSender, postRestart, receive, self, sender, supervisorStrategy

Methods inherited from interface akka.actor.StashSupport

$init$, context, self

Methods inherited from interface akka.actor.StashFactory

$init$

Methods inherited from interface akka.persistence.PersistenceIdentity

$init$

Methods inherited from interface akka.persistence.PersistenceRecovery

$init$

Constructor Detail

RpcRegistry

public RpcRegistry(RemoteRpcProviderConfig config,
                   akka.actor.ActorRef rpcInvoker,
                   akka.actor.ActorRef rpcRegistrar)

Method Detail

props

public 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.

Parameters:

config - Provider configuration

rpcRegistrar - Local RPC provider interface, used to register routers to remote nodes

rpcInvoker - Actor handling RPC invocation requests from remote nodes

Returns:

A new Props instance

postStop

public void postStop()
              throws Exception

Specified by:

postStop in interface akka.actor.Actor

Specified by:

postStop in interface akka.actor.UnrestrictedStash

Overrides:

postStop in class akka.persistence.UntypedPersistentActor

Throws:

Exception

handleCommand

protected void handleCommand(Object message)
                      throws Exception

Overrides:

handleCommand in class BucketStoreActor<RoutingTable>

Throws:

Exception

onBucketRemoved

protected void onBucketRemoved(akka.actor.Address address,
                               Bucket<RoutingTable> bucket)

Description copied from class: BucketStoreActor

Callback to subclasses invoked when a bucket is removed.

Specified by:

onBucketRemoved in class BucketStoreActor<RoutingTable>

Parameters:

address - Remote address

bucket - Bucket removed

onBucketsUpdated

protected void onBucketsUpdated(Map<akka.actor.Address,Bucket<RoutingTable>> buckets)

Description copied from class: BucketStoreActor

Callback to subclasses invoked when the set of remote buckets is updated.

Specified by:

onBucketsUpdated in class BucketStoreActor<RoutingTable>

Parameters:

buckets - Map of address to new bucket. Never null, but can be empty.