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 org.opendaylight.controller.cluster.common.actor.AbstractUntypedActor;
14 import org.opendaylight.mdsal.eos.dom.api.DOMEntityOwnershipChange;
15 import org.opendaylight.mdsal.eos.dom.api.DOMEntityOwnershipListener;
18 * An actor which is responsible for notifying an EntityOwnershipListener of changes.
20 * @author Thomas Pantelis
22 class EntityOwnershipListenerActor extends AbstractUntypedActor {
23 private final DOMEntityOwnershipListener listener;
25 private EntityOwnershipListenerActor(DOMEntityOwnershipListener listener) {
26 this.listener = listener;
30 protected void handleReceive(Object message) {
31 if (message instanceof DOMEntityOwnershipChange) {
32 onEntityOwnershipChanged((DOMEntityOwnershipChange)message);
34 unknownMessage(message);
38 @SuppressWarnings("checkstyle:IllegalCatch")
39 private void onEntityOwnershipChanged(DOMEntityOwnershipChange change) {
40 LOG.debug("Notifying EntityOwnershipListener {}: {}", listener, change);
43 listener.ownershipChanged(change);
44 } catch (Exception e) {
45 LOG.error("Error notifying listener {}", listener, e);
49 static Props props(DOMEntityOwnershipListener listener) {
50 return Props.create(new EntityOwnershipListenerCreator(listener));
53 private static final class EntityOwnershipListenerCreator implements Creator<EntityOwnershipListenerActor> {
54 private static final long serialVersionUID = 1L;
56 private final DOMEntityOwnershipListener listener;
58 EntityOwnershipListenerCreator(DOMEntityOwnershipListener listener) {
59 this.listener = Preconditions.checkNotNull(listener);
63 public EntityOwnershipListenerActor create() {
64 return new EntityOwnershipListenerActor(listener);