private ConsumerContext consumerContext = null;
private DataBroker dataBroker;
private NotificationProviderService notificationService;
- private FlowCapableNodeDataChangeListener flowCapableNodeChangeListener;
static final Logger logger = LoggerFactory.getLogger(MdsalConsumerImpl.class);
}
}
- void start() {
- }
-
- void stop() {
- }
-
@Override
public void onSessionInitialized(ConsumerContext session) {
this.consumerContext = session;
dataBroker = session.getSALService(DataBroker.class);
logger.info("OVSDB Neutron Session Initialized with CONSUMER CONTEXT {}", session.toString());
- flowCapableNodeChangeListener = new FlowCapableNodeDataChangeListener(dataBroker);
}
@Override
public void onSessionInitiated(ProviderContext session) {
notificationService = session.getSALService(NotificationProviderService.class);
}
-
- @Override
- public void notifyFlowCapableNodeCreateEvent(String openFlowId, Action action) {
- if (flowCapableNodeChangeListener != null) {
- flowCapableNodeChangeListener.notifyFlowCapableNodeEvent(openFlowId, action);
- }
- }
}