org.opendaylight.controller.cluster.datastore

Class ShardDataTreeNotificationPublisherActor<T extends org.opendaylight.controller.cluster.datastore.ShardDataTreeNotificationPublisher>

java.lang.Object

akka.actor.UntypedActor

org.opendaylight.controller.cluster.common.actor.AbstractUntypedActor

org.opendaylight.controller.cluster.datastore.ShardDataTreeNotificationPublisherActor<T>

All Implemented Interfaces:

akka.actor.Actor, ExecuteInSelfActor

Direct Known Subclasses:

ShardDataTreeChangePublisherActor

public class ShardDataTreeNotificationPublisherActor<T extends org.opendaylight.controller.cluster.datastore.ShardDataTreeNotificationPublisher>
extends AbstractUntypedActor

Actor used to generate and publish data tree notifications. This is used to offload the potentially expensive notification generation from the Shard actor.

Author:

Thomas Pantelis

Nested Class Summary

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

LOG

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ShardDataTreeNotificationPublisherActor(T publisher, String name, String logContext)

Method Summary

Modifier and Type	Method and Description
protected void	handleReceive(Object message) Receive and handle an incoming message.
protected String	logContext()
protected T	publisher()

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

executeInSelf, ignoreMessage, isValidSender, onReceive, unknownMessage

Methods inherited from class akka.actor.UntypedActor

akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, getContext, getSelf, getSender, postRestart, postStop, preRestart, preStart, receive, self, sender, supervisorStrategy, unhandled

Methods inherited from class java.lang.Object

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

Methods inherited from interface akka.actor.Actor

$init$, noSender

Constructor Detail

ShardDataTreeNotificationPublisherActor

protected ShardDataTreeNotificationPublisherActor(T publisher,
                                                  String name,
                                                  String logContext)

Method Detail

publisher

protected T publisher()

logContext

protected String logContext()

handleReceive

protected void handleReceive(Object message)

Description copied from class: AbstractUntypedActor

Receive and handle an incoming message. If the implementation does not handle this particular message, it should call AbstractUntypedActor.ignoreMessage(Object) or AbstractUntypedActor.unknownMessage(Object).

Specified by:

handleReceive in class AbstractUntypedActor

Parameters:

message - the incoming message