2 * Copyright (c) 2015 Brocade Communications Systems, Inc. and others. All rights reserved.
4 * This program and the accompanying materials are made available under the
5 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6 * and is available at http://www.eclipse.org/legal/epl-v10.html
8 package org.opendaylight.controller.cluster.datastore.entityownership;
10 import akka.actor.Props;
11 import akka.japi.Creator;
12 import com.google.common.base.Preconditions;
13 import edu.umd.cs.findbugs.annotations.SuppressFBWarnings;
14 import org.opendaylight.controller.cluster.common.actor.AbstractUntypedActor;
15 import org.opendaylight.mdsal.eos.dom.api.DOMEntityOwnershipChange;
16 import org.opendaylight.mdsal.eos.dom.api.DOMEntityOwnershipListener;
19 * An actor which is responsible for notifying an EntityOwnershipListener of changes.
21 * @author Thomas Pantelis
23 final class EntityOwnershipListenerActor extends AbstractUntypedActor {
24 private final DOMEntityOwnershipListener listener;
26 private EntityOwnershipListenerActor(final DOMEntityOwnershipListener listener) {
27 this.listener = listener;
31 protected void handleReceive(final Object message) {
32 if (message instanceof DOMEntityOwnershipChange) {
33 onEntityOwnershipChanged((DOMEntityOwnershipChange)message);
35 unknownMessage(message);
39 @SuppressWarnings("checkstyle:IllegalCatch")
40 private void onEntityOwnershipChanged(final DOMEntityOwnershipChange change) {
41 LOG.debug("Notifying EntityOwnershipListener {}: {}", listener, change);
44 listener.ownershipChanged(change);
45 } catch (Exception e) {
46 LOG.error("Error notifying listener {}", listener, e);
50 static Props props(final DOMEntityOwnershipListener listener) {
51 return Props.create(new EntityOwnershipListenerCreator(listener));
54 private static final class EntityOwnershipListenerCreator implements Creator<EntityOwnershipListenerActor> {
55 private static final long serialVersionUID = 1L;
57 @SuppressFBWarnings(value = "SE_BAD_FIELD", justification = "This field is not Serializable but we don't "
58 + "create remote instances of this actor and thus don't need it to be Serializable.")
59 private final DOMEntityOwnershipListener listener;
61 EntityOwnershipListenerCreator(final DOMEntityOwnershipListener listener) {
62 this.listener = Preconditions.checkNotNull(listener);
66 public EntityOwnershipListenerActor create() {
67 return new EntityOwnershipListenerActor(listener);