X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2Fentityownership%2FEntityOwnershipListenerActor.java;h=0a1bb923996f6bbd87bbc2f5cfafa24e3f185d2b;hb=c9587253579a7b34f4c397a254f83890d4d3ba03;hp=df0b1ae41dc221de7f90fdff00a27b0415e1d003;hpb=6b31b94c7c06711efd69f7fd456167026f34dc2e;p=controller.git diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/entityownership/EntityOwnershipListenerActor.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/entityownership/EntityOwnershipListenerActor.java index df0b1ae41d..0a1bb92399 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/entityownership/EntityOwnershipListenerActor.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/entityownership/EntityOwnershipListenerActor.java @@ -7,31 +7,29 @@ */ package org.opendaylight.controller.cluster.datastore.entityownership; +import static java.util.Objects.requireNonNull; + import akka.actor.Props; import akka.japi.Creator; -import com.google.common.base.Preconditions; +import edu.umd.cs.findbugs.annotations.SuppressFBWarnings; import org.opendaylight.controller.cluster.common.actor.AbstractUntypedActor; import org.opendaylight.mdsal.eos.dom.api.DOMEntityOwnershipChange; import org.opendaylight.mdsal.eos.dom.api.DOMEntityOwnershipListener; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; /** * An actor which is responsible for notifying an EntityOwnershipListener of changes. * * @author Thomas Pantelis */ -class EntityOwnershipListenerActor extends AbstractUntypedActor { - private static final Logger LOG = LoggerFactory.getLogger(EntityOwnershipListenerActor.class); - +final class EntityOwnershipListenerActor extends AbstractUntypedActor { private final DOMEntityOwnershipListener listener; - private EntityOwnershipListenerActor(DOMEntityOwnershipListener listener) { + private EntityOwnershipListenerActor(final DOMEntityOwnershipListener listener) { this.listener = listener; } @Override - protected void handleReceive(Object message) { + protected void handleReceive(final Object message) { if (message instanceof DOMEntityOwnershipChange) { onEntityOwnershipChanged((DOMEntityOwnershipChange)message); } else { @@ -39,7 +37,8 @@ class EntityOwnershipListenerActor extends AbstractUntypedActor { } } - private void onEntityOwnershipChanged(DOMEntityOwnershipChange change) { + @SuppressWarnings("checkstyle:IllegalCatch") + private void onEntityOwnershipChanged(final DOMEntityOwnershipChange change) { LOG.debug("Notifying EntityOwnershipListener {}: {}", listener, change); try { @@ -49,17 +48,19 @@ class EntityOwnershipListenerActor extends AbstractUntypedActor { } } - static Props props(DOMEntityOwnershipListener listener) { + static Props props(final DOMEntityOwnershipListener listener) { return Props.create(new EntityOwnershipListenerCreator(listener)); } private static final class EntityOwnershipListenerCreator implements Creator { private static final long serialVersionUID = 1L; + @SuppressFBWarnings(value = "SE_BAD_FIELD", justification = "This field is not Serializable but we don't " + + "create remote instances of this actor and thus don't need it to be Serializable.") private final DOMEntityOwnershipListener listener; - EntityOwnershipListenerCreator(DOMEntityOwnershipListener listener) { - this.listener = Preconditions.checkNotNull(listener); + EntityOwnershipListenerCreator(final DOMEntityOwnershipListener listener) { + this.listener = requireNonNull(listener); } @Override