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.controller.cluster.datastore.entityownership.messages.EntityOwnershipChanged;
15 import org.opendaylight.controller.md.sal.common.api.clustering.EntityOwnershipListener;
16 import org.slf4j.Logger;
17 import org.slf4j.LoggerFactory;
20 * An actor which is responsible for notifying an EntityOwnershipListener of changes.
22 * @author Thomas Pantelis
24 class EntityOwnershipListenerActor extends AbstractUntypedActor {
25 private static final Logger LOG = LoggerFactory.getLogger(EntityOwnershipListenerActor.class);
27 private final EntityOwnershipListener listener;
29 private EntityOwnershipListenerActor(EntityOwnershipListener listener) {
30 this.listener = listener;
34 protected void handleReceive(Object message) {
35 if(message instanceof EntityOwnershipChanged) {
36 onEntityOwnershipChanged((EntityOwnershipChanged)message);
40 private void onEntityOwnershipChanged(EntityOwnershipChanged change) {
41 LOG.debug("Notifying EntityOwnershipListener {}: {}", listener, change);
44 listener.ownershipChanged(change.getEntity(), change.wasOwner(), change.isOwner());
45 } catch (Exception e) {
46 LOG.error("Error notifying listener {}", listener, e);
50 static Props props(EntityOwnershipListener 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 private final EntityOwnershipListener listener;
59 EntityOwnershipListenerCreator(EntityOwnershipListener listener) {
60 this.listener = Preconditions.checkNotNull(listener);
64 public EntityOwnershipListenerActor create() {
65 return new EntityOwnershipListenerActor(listener);