Make Netty-3 dependency optional

[controller.git] / opendaylight / md-sal / sal-akka-raft / src / test / java / org / opendaylight / controller / cluster / raft / behaviors / SyncStatusTrackerTest.java

diff --git a/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/behaviors/SyncStatusTrackerTest.java b/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/behaviors/SyncStatusTrackerTest.java
index 3ffaeb811c6c6f4f965ca7330fd5d95f0d82a9d6..fdbab2b81a44f48ca6c80b05520bf6bab788d2f2 100644 (file)
--- a/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/behaviors/SyncStatusTrackerTest.java
+++ b/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/behaviors/SyncStatusTrackerTest.java
@@ -14,8 +14,8 @@ import static org.junit.Assert.assertNotNull;
 import static org.junit.Assert.assertNull;
 import static org.junit.Assert.assertTrue;
 import static org.junit.Assert.fail;
-import akka.actor.Props;
-import akka.testkit.TestActorRef;
+
+import akka.actor.ActorRef;
 import org.junit.After;
 import org.junit.Test;
 import org.opendaylight.controller.cluster.raft.AbstractActorTest;
@@ -26,16 +26,16 @@ import org.opendaylight.controller.cluster.raft.utils.MessageCollectorActor;
 public class SyncStatusTrackerTest extends AbstractActorTest {
     protected final TestActorFactory actorFactory = new TestActorFactory(getSystem());
 
-    private final TestActorRef<MessageCollectorActor> listener = actorFactory.createTestActor(
-            Props.create(MessageCollectorActor.class), actorFactory.generateActorId("listener"));
+    private final ActorRef listener = actorFactory.createActor(
+            MessageCollectorActor.props(), actorFactory.generateActorId("listener"));
 
     @After
-    public void tearDown(){
+    public void tearDown() {
         actorFactory.close();
     }
 
     @Test
-    public void testUpdate() throws Exception {
+    public void testUpdate() {
         SyncStatusTracker tracker = new SyncStatusTracker(listener, "commit-tracker", 10);
 
         // When leader-1 sends the first update message the listener should receive a syncStatus notification
@@ -111,33 +111,32 @@ public class SyncStatusTrackerTest extends AbstractActorTest {
     }
 
     @Test
-    public void testConstructorActorShouldNotBeNull(){
+    public void testConstructorActorShouldNotBeNull() {
         try {
             new SyncStatusTracker(null, "commit-tracker", 10);
             fail("A NullPointerException was expected");
-        } catch(NullPointerException e){
+        } catch (NullPointerException e) {
             assertTrue("Invalid error message :" + e.getMessage(), e.getMessage().contains("actor "));
         }
     }
 
     @Test
-    public void testConstructorIdShouldNotBeNull(){
+    public void testConstructorIdShouldNotBeNull() {
         try {
             new SyncStatusTracker(listener, null, 10);
             fail("A NullPointerException was expected");
-        } catch(NullPointerException e){
+        } catch (NullPointerException e) {
             assertTrue("Invalid error message :" + e.getMessage(), e.getMessage().contains("id "));
         }
     }
 
     @Test
-    public void testConstructorSyncThresholdShouldNotBeNegative(){
+    public void testConstructorSyncThresholdShouldNotBeNegative() {
         try {
             new SyncStatusTracker(listener, "commit-tracker", -1);
             fail("An IllegalArgumentException was expected");
-        } catch(IllegalArgumentException e){
+        } catch (IllegalArgumentException e) {
             assertTrue("Invalid error message :" + e.getMessage(), e.getMessage().contains("syncThreshold "));
         }
     }
-
-}
\ No newline at end of file
+}