Decompose RPC implementation classes
[openflowplugin.git] / openflowplugin-impl / src / main / java / org / opendaylight / openflowplugin / impl / statistics / services / GetNodeConnectorStatisticsImpl.java
@@ -12,35 +12,26 @@ import java.util.concurrent.atomic.AtomicLong;
 import org.opendaylight.mdsal.binding.api.NotificationPublishService;
 import org.opendaylight.openflowplugin.api.openflow.device.DeviceContext;
 import org.opendaylight.openflowplugin.api.openflow.device.RequestContextStack;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.port.statistics.rev131214.GetAllNodeConnectorsStatisticsInput;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.port.statistics.rev131214.GetAllNodeConnectorsStatisticsOutput;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.port.statistics.rev131214.GetNodeConnectorStatistics;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.port.statistics.rev131214.GetNodeConnectorStatisticsInput;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.port.statistics.rev131214.GetNodeConnectorStatisticsOutput;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.port.statistics.rev131214.OpendaylightPortStatisticsService;
 import org.opendaylight.yangtools.yang.common.RpcResult;
 
-public class OpendaylightPortStatisticsServiceImpl implements OpendaylightPortStatisticsService {
-    private final AllPortStatsService allPortStats;
+@Deprecated
+public final class GetNodeConnectorStatisticsImpl implements GetNodeConnectorStatistics {
     private final PortStatsService portStats;
     private final NotificationPublishService notificationPublishService;
 
-    public OpendaylightPortStatisticsServiceImpl(final RequestContextStack requestContextStack,
+    public GetNodeConnectorStatisticsImpl(final RequestContextStack requestContextStack,
                                                  final DeviceContext deviceContext,
                                                  final AtomicLong compatibilityXidSeed,
                                                  final NotificationPublishService notificationPublishService) {
         this.notificationPublishService = notificationPublishService;
-        allPortStats = new AllPortStatsService(requestContextStack, deviceContext, compatibilityXidSeed);
         portStats = new PortStatsService(requestContextStack, deviceContext, compatibilityXidSeed);
     }
 
     @Override
-    public ListenableFuture<RpcResult<GetAllNodeConnectorsStatisticsOutput>> getAllNodeConnectorsStatistics(
-            final GetAllNodeConnectorsStatisticsInput input) {
-        return allPortStats.handleAndNotify(input, notificationPublishService);
-    }
-
-    @Override
-    public ListenableFuture<RpcResult<GetNodeConnectorStatisticsOutput>> getNodeConnectorStatistics(
+    public ListenableFuture<RpcResult<GetNodeConnectorStatisticsOutput>> invoke(
             final GetNodeConnectorStatisticsInput input) {
         return portStats.handleAndNotify(input, notificationPublishService);
     }