Bug 8231: Fix testChangeListenerRegistration failure

[controller.git] / opendaylight / md-sal / sal-distributed-datastore / src / main / java / org / opendaylight / controller / cluster / datastore / DataTreeChangeListenerRegistrationActor.java

diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/DataTreeChangeListenerRegistrationActor.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/DataTreeChangeListenerRegistrationActor.java
deleted file mode 100644 (file)
index 17deeeb..0000000
--- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/DataTreeChangeListenerRegistrationActor.java
+++ /dev/null
@@ -1,67 +0,0 @@
-/*
- * Copyright (c) 2015 Cisco Systems, Inc. and others.  All rights reserved.
- *
- * This program and the accompanying materials are made available under the
- * terms of the Eclipse Public License v1.0 which accompanies this distribution,
- * and is available at http://www.eclipse.org/legal/epl-v10.html
- */
-package org.opendaylight.controller.cluster.datastore;
-
-import akka.actor.PoisonPill;
-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.controller.cluster.datastore.messages.CloseDataTreeChangeListenerRegistration;
-import org.opendaylight.controller.cluster.datastore.messages.CloseDataTreeChangeListenerRegistrationReply;
-import org.opendaylight.controller.md.sal.dom.api.DOMDataTreeChangeListener;
-import org.opendaylight.yangtools.concepts.ListenerRegistration;
-
-/**
- * Actor co-located with a shard. It exists only to terminate the registration when
- * asked to do so via {@link CloseDataTreeChangeListenerRegistration}.
- */
-public final class DataTreeChangeListenerRegistrationActor extends AbstractUntypedActor {
-    private final ListenerRegistration<DOMDataTreeChangeListener> registration;
-
-    public DataTreeChangeListenerRegistrationActor(final ListenerRegistration<DOMDataTreeChangeListener> registration) {
-        this.registration = Preconditions.checkNotNull(registration);
-    }
-
-    @Override
-    protected void handleReceive(Object message) throws Exception {
-        if (message instanceof CloseDataTreeChangeListenerRegistration) {
-            registration.close();
-            if (isValidSender(getSender())) {
-                getSender().tell(CloseDataTreeChangeListenerRegistrationReply.getInstance(), getSelf());
-            }
-
-            getSelf().tell(PoisonPill.getInstance(), getSelf());
-        } else {
-            unknownMessage(message);
-        }
-    }
-
-    public static Props props(final ListenerRegistration<DOMDataTreeChangeListener> registration) {
-        return Props.create(new DataTreeChangeListenerRegistrationCreator(registration));
-    }
-
-    private static final class DataTreeChangeListenerRegistrationCreator
-            implements Creator<DataTreeChangeListenerRegistrationActor> {
-        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.")
-        final ListenerRegistration<DOMDataTreeChangeListener> registration;
-
-        DataTreeChangeListenerRegistrationCreator(ListenerRegistration<DOMDataTreeChangeListener> registration) {
-            this.registration = Preconditions.checkNotNull(registration);
-        }
-
-        @Override
-        public DataTreeChangeListenerRegistrationActor create() {
-            return new DataTreeChangeListenerRegistrationActor(registration);
-        }
-    }
-}