OPNFLWPLUG-1032: Neon-MRI: Bump odlparent, yangtools, mdsal
[openflowplugin.git] / openflowjava / openflow-protocol-impl / src / test / java / org / opendaylight / openflowjava / protocol / impl / core / connection / SimpleRpcListenerTest.java
index 7726000532b4d5bfa57af446982ec375c20a16df..11da2f0dd9cc94395d58d98fb1d5e5de48b9077f 100644 (file)
@@ -12,6 +12,7 @@ import static org.junit.Assert.fail;
 import static org.mockito.Mockito.times;
 import static org.mockito.Mockito.verify;
 import static org.mockito.Mockito.when;
+
 import com.google.common.util.concurrent.SettableFuture;
 import io.netty.util.concurrent.Future;
 import java.util.concurrent.ExecutionException;
@@ -24,15 +25,16 @@ import org.opendaylight.yangtools.yang.common.RpcResult;
 import org.opendaylight.yangtools.yang.common.RpcResultBuilder;
 
 /**
- * @author michal.polkorab
+ * UNit tests for SimpleRpcListener.
  *
+ * @author michal.polkorab
  */
 public class SimpleRpcListenerTest {
 
     @Mock Future<Void> future;
 
     /**
-     * Initializes mocks
+     * Initializes mocks.
      */
     @Before
     public void startUp() {
@@ -40,7 +42,7 @@ public class SimpleRpcListenerTest {
     }
 
     /**
-     * Test SimpleRpcListener creation
+     * Test SimpleRpcListener creation.
      */
     @Test
     public void test() {
@@ -50,11 +52,11 @@ public class SimpleRpcListenerTest {
     }
 
     /**
-     * Test rpc success
+     * Test rpc success.
      */
     @Test
     public void testSuccessfulRpc() {
-        SimpleRpcListener listener = new SimpleRpcListener("MESSAGE", "Failed to send message");
+        SimpleRpcListener<?> listener = new SimpleRpcListener("MESSAGE", "Failed to send message");
         listener.operationSuccessful();
         SettableFuture<RpcResult<?>> result = SettableFuture.create();
         result.set(RpcResultBuilder.success((Void)null).build());
@@ -68,12 +70,12 @@ public class SimpleRpcListenerTest {
     }
 
     /**
-     * Test rpc success
+     * Test rpc success.
      */
     @Test
     public void testOperationComplete() {
         when(future.isSuccess()).thenReturn(false);
-        SimpleRpcListener listener = new SimpleRpcListener("MESSAGE", "Failed to send message");
+        SimpleRpcListener<?> listener = new SimpleRpcListener("MESSAGE", "Failed to send message");
         listener.operationComplete(future);
         verify(future, times(1)).cause();
         try {
@@ -84,12 +86,12 @@ public class SimpleRpcListenerTest {
     }
 
     /**
-     * Test rpc success
+     * Test rpc success.
      */
     @Test
     public void testOperationComplete2() {
         when(future.isSuccess()).thenReturn(true);
-        SimpleRpcListener listener = new SimpleRpcListener("MESSAGE", "Failed to send message");
+        SimpleRpcListener<?> listener = new SimpleRpcListener("MESSAGE", "Failed to send message");
         listener.operationComplete(future);
         verify(future, times(0)).cause();
         try {
@@ -99,4 +101,4 @@ public class SimpleRpcListenerTest {
             Assert.fail();
         }
     }
-}
\ No newline at end of file
+}