X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-clustering-commons%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fcommon%2Factor%2FAbstractUntypedActor.java;fp=opendaylight%2Fmd-sal%2Fsal-clustering-commons%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fcommon%2Factor%2FAbstractUntypedActor.java;h=ca303a5c12ee54749b1ddcbaf24e1cb4bf8f522b;hp=dffb6101c53d84ac621421c5fe4021fd640630dd;hb=34dd0235a4f8e27032f725047d11c21526187373;hpb=0e5d0eeeda176fe4ef0d5f65097998b32e38abf1 diff --git a/opendaylight/md-sal/sal-clustering-commons/src/main/java/org/opendaylight/controller/cluster/common/actor/AbstractUntypedActor.java b/opendaylight/md-sal/sal-clustering-commons/src/main/java/org/opendaylight/controller/cluster/common/actor/AbstractUntypedActor.java index dffb6101c5..ca303a5c12 100644 --- a/opendaylight/md-sal/sal-clustering-commons/src/main/java/org/opendaylight/controller/cluster/common/actor/AbstractUntypedActor.java +++ b/opendaylight/md-sal/sal-clustering-commons/src/main/java/org/opendaylight/controller/cluster/common/actor/AbstractUntypedActor.java @@ -8,6 +8,7 @@ package org.opendaylight.controller.cluster.common.actor; +import akka.actor.ActorRef; import akka.actor.UntypedActor; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -42,4 +43,10 @@ public abstract class AbstractUntypedActor extends UntypedActor { LOG.debug("Received unhandled message {}", message); unhandled(message); } + + protected boolean isValidSender(ActorRef sender) { + // If the caller passes in a null sender (ActorRef.noSender()), akka translates that to the + // deadLetters actor. + return sender != null && !getContext().system().deadLetters().equals(sender); + } }