Code Review
/
controller.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Fix raw reference
[controller.git]
/
opendaylight
/
md-sal
/
sal-distributed-datastore
/
src
/
test
/
java
/
org
/
opendaylight
/
controller
/
cluster
/
datastore
/
utils
/
TestUtils.java
diff --git
a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/utils/TestUtils.java
b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/utils/TestUtils.java
index bb881d532263384a5828fdd5ec31b32040835242..8a141fb9b35789907b587facdbcda041f376d57e 100644
(file)
--- a/
opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/utils/TestUtils.java
+++ b/
opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/utils/TestUtils.java
@@
-11,24
+11,24
@@
package org.opendaylight.controller.cluster.datastore.utils;
import akka.actor.ActorRef;
import akka.actor.ActorSystem;
import akka.actor.Props;
import akka.actor.ActorRef;
import akka.actor.ActorSystem;
import akka.actor.Props;
-import junit.framework.Assert;
-
import java.util.List;
import java.util.List;
+import org.junit.Assert;
+import org.opendaylight.controller.cluster.raft.utils.DoNothingActor;
+import org.opendaylight.controller.cluster.raft.utils.MessageCollectorActor;
public class TestUtils {
public class TestUtils {
- public static void assertFirstSentMessage(
ActorSystem actorSystem, ActorRef actorRef, Class
clazz){
+ public static void assertFirstSentMessage(
final ActorSystem actorSystem, final ActorRef actorRef, final Class<?>
clazz){
ActorContext testContext = new ActorContext(actorSystem, actorSystem.actorOf(
ActorContext testContext = new ActorContext(actorSystem, actorSystem.actorOf(
- Props.create(DoNothingActor.class)));
+ Props.create(DoNothingActor.class))
, new MockClusterWrapper(), new MockConfiguration()
);
Object messages = testContext
Object messages = testContext
- .executeLocalOperation(actorRef, "messages",
- ActorContext.ASK_DURATION);
+ .executeOperation(actorRef, MessageCollectorActor.GET_ALL_MESSAGES);
Assert.assertNotNull(messages);
Assert.assertTrue(messages instanceof List);
Assert.assertNotNull(messages);
Assert.assertTrue(messages instanceof List);
- List<
Object> listMessages = (List<Object
>) messages;
+ List<
?> listMessages = (List<?
>) messages;
Assert.assertEquals(1, listMessages.size());
Assert.assertEquals(1, listMessages.size());