Rename ActorContext to ActorUtils

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

diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/TransactionReadyReplyMapper.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/TransactionReadyReplyMapper.java
index d1774980bf1f6a8400b69c4e9dca355d0c06725c..f5eb0e4be68fc023bc995f5f49c286a1537438d6 100644 (file)
--- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/TransactionReadyReplyMapper.java
+++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/TransactionReadyReplyMapper.java
@@ -7,12 +7,13 @@
  */
 package org.opendaylight.controller.cluster.datastore;
 
+import static java.util.Objects.requireNonNull;
+
 import akka.actor.ActorSelection;
 import akka.dispatch.Mapper;
-import com.google.common.base.Preconditions;
 import org.opendaylight.controller.cluster.access.concepts.TransactionIdentifier;
 import org.opendaylight.controller.cluster.datastore.messages.ReadyTransactionReply;
-import org.opendaylight.controller.cluster.datastore.utils.ActorContext;
+import org.opendaylight.controller.cluster.datastore.utils.ActorUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import scala.concurrent.Future;
@@ -35,15 +36,15 @@ public class TransactionReadyReplyMapper extends Mapper<Object, ActorSelection>
     };
     private static final Logger LOG = LoggerFactory.getLogger(TransactionReadyReplyMapper.class);
     private final TransactionIdentifier identifier;
-    private final ActorContext actorContext;
+    private final ActorUtils actorUtils;
 
-    protected TransactionReadyReplyMapper(final ActorContext actorContext, final TransactionIdentifier identifier) {
-        this.actorContext = Preconditions.checkNotNull(actorContext);
-        this.identifier = Preconditions.checkNotNull(identifier);
+    protected TransactionReadyReplyMapper(final ActorUtils actorUtils, final TransactionIdentifier identifier) {
+        this.actorUtils = requireNonNull(actorUtils);
+        this.identifier = requireNonNull(identifier);
     }
 
-    protected final ActorContext getActorContext() {
-        return actorContext;
+    protected final ActorUtils getActorUtils() {
+        return actorUtils;
     }
 
     protected String extractCohortPathFrom(final ReadyTransactionReply readyTxReply) {
@@ -58,7 +59,7 @@ public class TransactionReadyReplyMapper extends Mapper<Object, ActorSelection>
         // actor path from the reply.
         if (ReadyTransactionReply.isSerializedType(serializedReadyReply)) {
             ReadyTransactionReply readyTxReply = ReadyTransactionReply.fromSerializable(serializedReadyReply);
-            return actorContext.actorSelection(extractCohortPathFrom(readyTxReply));
+            return actorUtils.actorSelection(extractCohortPathFrom(readyTxReply));
         }
 
         // Throwing an exception here will fail the Future.
@@ -66,9 +67,9 @@ public class TransactionReadyReplyMapper extends Mapper<Object, ActorSelection>
                 identifier, serializedReadyReply.getClass()));
     }
 
-    static Future<ActorSelection> transform(final Future<Object> readyReplyFuture, final ActorContext actorContext,
+    static Future<ActorSelection> transform(final Future<Object> readyReplyFuture, final ActorUtils actorUtils,
             final TransactionIdentifier identifier) {
-        return readyReplyFuture.transform(new TransactionReadyReplyMapper(actorContext, identifier),
-            SAME_FAILURE_TRANSFORMER, actorContext.getClientDispatcher());
+        return readyReplyFuture.transform(new TransactionReadyReplyMapper(actorUtils, identifier),
+            SAME_FAILURE_TRANSFORMER, actorUtils.getClientDispatcher());
     }
 }