Adjust to yangtools-2.0.0/odlparent-3.0.0 changes
[netconf.git] / netconf / sal-netconf-connector / src / test / java / org / opendaylight / netconf / sal / connect / netconf / listener / NetconfDeviceCommunicatorTest.java
index f9724cf74ee12e2e48e85880e273401e75ef2505..3cc75f230ac289be80ea97122f40ff9edb1a0eaf 100644 (file)
@@ -11,6 +11,7 @@ package org.opendaylight.netconf.sal.connect.netconf.listener;
 import static org.junit.Assert.assertEquals;
 import static org.junit.Assert.assertFalse;
 import static org.junit.Assert.assertNotNull;
+import static org.junit.Assert.assertTrue;
 import static org.mockito.Matchers.any;
 import static org.mockito.Matchers.eq;
 import static org.mockito.Matchers.same;
@@ -115,11 +116,11 @@ public class NetconfDeviceCommunicatorTest {
 
         ChannelFuture mockChannelFuture = mock(ChannelFuture.class);
         doReturn(mockChannelFuture).when(mockChannelFuture)
-                .addListener(any((GenericFutureListener.class)));
+                .addListener(any(GenericFutureListener.class));
         doReturn(mockChannelFuture).when(mockSession).sendMessage(same(message));
 
         ListenableFuture<RpcResult<NetconfMessage>> resultFuture =
-                communicator.sendRequest(message, QName.create("mock rpc"));
+                communicator.sendRequest(message, QName.create("", "mockRpc"));
         if (doLastTest) {
             assertNotNull("ListenableFuture is null", resultFuture);
         }
@@ -210,7 +211,7 @@ public class NetconfDeviceCommunicatorTest {
         setupSession();
 
         NetconfMessage message = new NetconfMessage(UntrustedXML.newDocumentBuilder().newDocument());
-        QName rpc = QName.create("mock rpc");
+        QName rpc = QName.create("", "mockRpc");
 
         ArgumentCaptor<GenericFutureListener> futureListener =
                 ArgumentCaptor.forClass(GenericFutureListener.class);
@@ -241,7 +242,7 @@ public class NetconfDeviceCommunicatorTest {
     @Test
     public void testSendRequestWithNoSession() throws Exception {
         NetconfMessage message = new NetconfMessage(UntrustedXML.newDocumentBuilder().newDocument());
-        QName rpc = QName.create("mock rpc");
+        QName rpc = QName.create("", "mockRpc");
 
         ListenableFuture<RpcResult<NetconfMessage>> resultFuture = communicator.sendRequest(message, rpc);
 
@@ -273,7 +274,7 @@ public class NetconfDeviceCommunicatorTest {
         setupSession();
 
         NetconfMessage message = new NetconfMessage(UntrustedXML.newDocumentBuilder().newDocument());
-        QName rpc = QName.create("mock rpc");
+        QName rpc = QName.create("", "mockRpc");
 
         ArgumentCaptor<GenericFutureListener> futureListener =
                 ArgumentCaptor.forClass(GenericFutureListener.class);
@@ -355,10 +356,8 @@ public class NetconfDeviceCommunicatorTest {
 
         String errorInfo = rpcError.getInfo();
         assertNotNull("RpcError info is null", errorInfo);
-        assertEquals("Error info contains \"foo\"", true,
-                errorInfo.contains("<bad-attribute>foo</bad-attribute>"));
-        assertEquals("Error info contains \"bar\"", true,
-                errorInfo.contains("<bad-element>bar</bad-element>"));
+        assertTrue("Error info contains \"foo\"", errorInfo.contains("<bad-attribute>foo</bad-attribute>"));
+        assertTrue("Error info contains \"bar\"", errorInfo.contains("<bad-element>bar</bad-element>"));
     }
 
     /**
@@ -424,15 +423,12 @@ public class NetconfDeviceCommunicatorTest {
 
         RpcError rpcError = verifyErrorRpcResult(resultFuture.get(), RpcError.ErrorType.PROTOCOL,
                 "bad-attribute");
-        assertEquals("RpcError message non-empty", true,
-                !Strings.isNullOrEmpty(rpcError.getMessage()));
+        assertFalse("RpcError message non-empty", Strings.isNullOrEmpty(rpcError.getMessage()));
 
         String errorInfo = rpcError.getInfo();
         assertNotNull("RpcError info is null", errorInfo);
-        assertEquals("Error info contains \"actual-message-id\"", true,
-                errorInfo.contains("actual-message-id"));
-        assertEquals("Error info contains \"expected-message-id\"", true,
-                errorInfo.contains("expected-message-id"));
+        assertTrue("Error info contains \"actual-message-id\"", errorInfo.contains("actual-message-id"));
+        assertTrue("Error info contains \"expected-message-id\"", errorInfo.contains("expected-message-id"));
     }
 
     @Test
@@ -478,7 +474,7 @@ public class NetconfDeviceCommunicatorTest {
 
     private static void verifyResponseMessage(final RpcResult<NetconfMessage> rpcResult, final String dataText) {
         assertNotNull("RpcResult is null", rpcResult);
-        assertEquals("isSuccessful", true, rpcResult.isSuccessful());
+        assertTrue("isSuccessful", rpcResult.isSuccessful());
         NetconfMessage messageResult = rpcResult.getResult();
         assertNotNull("getResult", messageResult);
 //        List<SimpleNode<?>> nodes = messageResult.getSimpleNodesByName(
@@ -491,7 +487,7 @@ public class NetconfDeviceCommunicatorTest {
     private static RpcError verifyErrorRpcResult(final RpcResult<NetconfMessage> rpcResult,
                                                  final RpcError.ErrorType expErrorType, final String expErrorTag) {
         assertNotNull("RpcResult is null", rpcResult);
-        assertEquals("isSuccessful", false, rpcResult.isSuccessful());
+        assertFalse("isSuccessful", rpcResult.isSuccessful());
         assertNotNull("RpcResult errors is null", rpcResult.getErrors());
         assertEquals("Errors size", 1, rpcResult.getErrors().size());
         RpcError rpcError = rpcResult.getErrors().iterator().next();
@@ -502,7 +498,7 @@ public class NetconfDeviceCommunicatorTest {
         final String msg = rpcError.getMessage();
         assertNotNull("getMessage is null", msg);
         assertFalse("getMessage is empty", msg.isEmpty());
-        assertFalse("getMessage is blank", CharMatcher.WHITESPACE.matchesAllOf(msg));
+        assertFalse("getMessage is blank", CharMatcher.whitespace().matchesAllOf(msg));
         return rpcError;
     }
 }