X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=openflowplugin-impl%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fopenflowplugin%2Fimpl%2Fdevice%2FDeviceManagerImpl.java;h=40020aee7cc0601a4950e9cacae6da52a6e08f1d;hb=fc2c4994e93731fa8c4cf685e3896bd63856e62b;hp=bcdb76413ef6d37d56e452eaf17fa603bdfc0d73;hpb=970ec2c0764f603bc657c4499aefec65a4e46cfa;p=openflowplugin.git

diff --git a/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/device/DeviceManagerImpl.java b/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/device/DeviceManagerImpl.java
index bcdb76413e..40020aee7c 100644
--- a/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/device/DeviceManagerImpl.java
+++ b/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/device/DeviceManagerImpl.java
@@ -7,6 +7,8 @@
  */
 package org.opendaylight.openflowplugin.impl.device;
 
+import org.opendaylight.controller.sal.binding.api.NotificationProviderService;
+
 import com.google.common.base.Preconditions;
 import com.google.common.util.concurrent.FutureCallback;
 import com.google.common.util.concurrent.Futures;
@@ -94,6 +96,7 @@ public class DeviceManagerImpl implements DeviceManager {
     private RequestContextStack dummyRequestContextStack;
     private TranslatorLibrary translatorLibrary;
     private DeviceInitializationPhaseHandler deviceInitPhaseHandler;
+    private NotificationProviderService notificationService;
 
 
     public DeviceManagerImpl(@Nonnull final DataBroker dataBroker) {
@@ -143,6 +146,7 @@ public class DeviceManagerImpl implements DeviceManager {
 
         final DeviceContextImpl deviceContext = new DeviceContextImpl(connectionContext, deviceState, dataBroker, hashedWheelTimer);
 
+        deviceContext.setNotificationService(notificationService);
         deviceContext.writeToTransaction(LogicalDatastoreType.OPERATIONAL, deviceState.getNodeInstanceIdentifier(), new NodeBuilder().setId(deviceState.getNodeId()).build());
 
         deviceContext.setTranslatorLibrary(translatorLibrary);
@@ -302,6 +306,7 @@ public class DeviceManagerImpl implements DeviceManager {
                         final NodeConnector connector = new NodeConnectorBuilder(portUpd).addAugmentation(FlowCapableNodeConnectorStatisticsData.class,
                                 new FlowCapableNodeConnectorStatisticsDataBuilder().build()).build();
                         dContext.writeToTransaction(LogicalDatastoreType.OPERATIONAL, connectorII, connector);
+                        //FlowCapableNodeConnectorBuilder
                     }
 
                 default:
@@ -309,4 +314,9 @@ public class DeviceManagerImpl implements DeviceManager {
             }
         }
     }
+
+    @Override
+    public void setNotificationService(final NotificationProviderService notificationServiceParam) {
+        notificationService = notificationServiceParam;
+    }
 }