Add single layer deserialization support
[openflowplugin.git] / openflowplugin-impl / src / test / java / org / opendaylight / openflowplugin / impl / statistics / services / direct / OpendaylightDirectStatisticsServiceImplTest.java
index c3a2c26a178656b7404a6835c28034dc80ab8e5b..73ef8601bde63dfc1b766169d366e7de74749717 100644 (file)
@@ -8,6 +8,11 @@
 
 package org.opendaylight.openflowplugin.impl.statistics.services.direct;
 
+import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertTrue;
+import static org.mockito.Mockito.times;
+import static org.mockito.Mockito.verify;
+
 import org.junit.Before;
 import org.junit.Test;
 import org.junit.runner.RunWith;
@@ -27,23 +32,18 @@ import org.opendaylight.yang.gen.v1.urn.opendaylight.direct.statistics.rev160511
 import org.opendaylight.yangtools.yang.common.RpcError;
 import org.opendaylight.yangtools.yang.common.RpcResult;
 
-import static org.junit.Assert.assertFalse;
-import static org.junit.Assert.assertTrue;
-import static org.mockito.Mockito.times;
-import static org.mockito.Mockito.verify;
-
 @RunWith(MockitoJUnitRunner.class)
 public class OpendaylightDirectStatisticsServiceImplTest {
     @Mock
-    FlowDirectStatisticsService flowDirectStatisticsService;
+    AbstractFlowDirectStatisticsService flowDirectStatisticsService;
     @Mock
-    GroupDirectStatisticsService groupDirectStatisticsService;
+    AbstractGroupDirectStatisticsService groupDirectStatisticsService;
     @Mock
-    MeterDirectStatisticsService meterDirectStatisticsService;
+    AbstractMeterDirectStatisticsService meterDirectStatisticsService;
     @Mock
-    NodeConnectorDirectStatisticsService nodeConnectorDirectStatisticsService;
+    AbstractPortDirectStatisticsService nodeConnectorDirectStatisticsService;
     @Mock
-    QueueDirectStatisticsService queueDirectStatisticsService;
+    AbstractQueueDirectStatisticsService queueDirectStatisticsService;
 
     @Mock
     GetGroupStatisticsInput getGroupStatisticsInput;
@@ -55,18 +55,18 @@ public class OpendaylightDirectStatisticsServiceImplTest {
     GetMeterStatisticsInput getMeterStatisticsInput;
     @Mock
     GetNodeConnectorStatisticsInput getNodeConnectorStatisticsInput;
-    
+
     private OpendaylightDirectStatisticsService service;
     private OpendaylightDirectStatisticsService emptyService;
 
     @Before
     public void setUp() throws Exception {
         final OpendaylightDirectStatisticsServiceProvider provider = new OpendaylightDirectStatisticsServiceProvider();
-        provider.register(FlowDirectStatisticsService.class, flowDirectStatisticsService);
-        provider.register(GroupDirectStatisticsService.class, groupDirectStatisticsService);
-        provider.register(MeterDirectStatisticsService.class, meterDirectStatisticsService);
-        provider.register(NodeConnectorDirectStatisticsService.class, nodeConnectorDirectStatisticsService);
-        provider.register(QueueDirectStatisticsService.class, queueDirectStatisticsService);
+        provider.register(AbstractFlowDirectStatisticsService.class, flowDirectStatisticsService);
+        provider.register(AbstractGroupDirectStatisticsService.class, groupDirectStatisticsService);
+        provider.register(AbstractMeterDirectStatisticsService.class, meterDirectStatisticsService);
+        provider.register(AbstractPortDirectStatisticsService.class, nodeConnectorDirectStatisticsService);
+        provider.register(AbstractQueueDirectStatisticsService.class, queueDirectStatisticsService);
 
         service = new OpendaylightDirectStatisticsServiceImpl(provider);
         emptyService = new OpendaylightDirectStatisticsServiceImpl(new OpendaylightDirectStatisticsServiceProvider());
@@ -87,7 +87,7 @@ public class OpendaylightDirectStatisticsServiceImplTest {
         assertFalse(result.isSuccessful());
 
         for (RpcError error : result.getErrors()) {
-            assertTrue(error.getMessage().contains(GroupDirectStatisticsService.class.getSimpleName()));
+            assertTrue(error.getMessage().contains(AbstractGroupDirectStatisticsService.class.getSimpleName()));
         }
 
         verify(groupDirectStatisticsService, times(0)).handleAndReply(getGroupStatisticsInput);
@@ -108,7 +108,7 @@ public class OpendaylightDirectStatisticsServiceImplTest {
         assertFalse(result.isSuccessful());
 
         for (RpcError error : result.getErrors()) {
-            assertTrue(error.getMessage().contains(QueueDirectStatisticsService.class.getSimpleName()));
+            assertTrue(error.getMessage().contains(AbstractQueueDirectStatisticsService.class.getSimpleName()));
         }
 
         verify(queueDirectStatisticsService, times(0)).handleAndReply(getQueueStatisticsInput);
@@ -129,7 +129,7 @@ public class OpendaylightDirectStatisticsServiceImplTest {
         assertFalse(result.isSuccessful());
 
         for (RpcError error : result.getErrors()) {
-            assertTrue(error.getMessage().contains(FlowDirectStatisticsService.class.getSimpleName()));
+            assertTrue(error.getMessage().contains(AbstractFlowDirectStatisticsService.class.getSimpleName()));
         }
 
         verify(flowDirectStatisticsService, times(0)).handleAndReply(getFlowStatisticsInput);
@@ -150,7 +150,7 @@ public class OpendaylightDirectStatisticsServiceImplTest {
         assertFalse(result.isSuccessful());
 
         for (RpcError error : result.getErrors()) {
-            assertTrue(error.getMessage().contains(MeterDirectStatisticsService.class.getSimpleName()));
+            assertTrue(error.getMessage().contains(AbstractMeterDirectStatisticsService.class.getSimpleName()));
         }
 
         verify(meterDirectStatisticsService, times(0)).handleAndReply(getMeterStatisticsInput);
@@ -171,9 +171,9 @@ public class OpendaylightDirectStatisticsServiceImplTest {
         assertFalse(result.isSuccessful());
 
         for (RpcError error : result.getErrors()) {
-            assertTrue(error.getMessage().contains(NodeConnectorDirectStatisticsService.class.getSimpleName()));
+            assertTrue(error.getMessage().contains(AbstractPortDirectStatisticsService.class.getSimpleName()));
         }
 
         verify(nodeConnectorDirectStatisticsService, times(0)).handleAndReply(getNodeConnectorStatisticsInput);
     }
-}
\ No newline at end of file
+}