Instantiate yang-data-codec-binfmt

[yangtools.git] / java / org / opendaylight / controller / cluster / common / actor / AbstractUntypedPersistentActor.java

diff --git a/java/org/opendaylight/controller/cluster/common/actor/AbstractUntypedPersistentActor.java b/java/org/opendaylight/controller/cluster/common/actor/AbstractUntypedPersistentActor.java
deleted file mode 100644 (file)
index 711a431..0000000
--- a/java/org/opendaylight/controller/cluster/common/actor/AbstractUntypedPersistentActor.java
+++ /dev/null
@@ -1,61 +0,0 @@
-/*
- * Copyright (c) 2014 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.common.actor;
-
-import akka.actor.ActorRef;
-import akka.persistence.AbstractPersistentActor;
-import edu.umd.cs.findbugs.annotations.SuppressFBWarnings;
-import org.eclipse.jdt.annotation.NonNull;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-public abstract class AbstractUntypedPersistentActor extends AbstractPersistentActor implements ExecuteInSelfActor {
-
-    // The member name should be lower case but it's referenced in many subclasses. Suppressing the CS warning for now.
-    @SuppressFBWarnings("SLF4J_LOGGER_SHOULD_BE_PRIVATE")
-    @SuppressWarnings("checkstyle:MemberName")
-    protected final Logger LOG = LoggerFactory.getLogger(getClass());
-
-    protected AbstractUntypedPersistentActor() {
-        LOG.trace("Actor created {}", getSelf());
-        getContext().system().actorSelection("user/termination-monitor").tell(new Monitor(getSelf()), getSelf());
-    }
-
-    @Override
-    public final void executeInSelf(@NonNull final Runnable runnable) {
-        final ExecuteInSelfMessage message = new ExecuteInSelfMessage(runnable);
-        LOG.trace("Scheduling execution of {}", message);
-        self().tell(message, ActorRef.noSender());
-    }
-
-    @Override
-    public final Receive createReceive() {
-        return receiveBuilder()
-                .match(ExecuteInSelfMessage.class, ExecuteInSelfMessage::run)
-                .matchAny(this::handleCommand)
-                .build();
-    }
-
-    @Override
-    public final Receive createReceiveRecover() {
-        return receiveBuilder().matchAny(this::handleRecover).build();
-    }
-
-    protected abstract void handleRecover(Object message) throws Exception;
-
-    protected abstract void handleCommand(Object message) throws Exception;
-
-    protected void ignoreMessage(final Object message) {
-        LOG.debug("Unhandled message {} ", message);
-    }
-
-    protected void unknownMessage(final Object message) {
-        LOG.debug("Received unhandled message {}", message);
-        unhandled(message);
-    }
-}