listenerRegistration?.close();
}
-}
-
-class NodeChangeCommiter implements OpendaylightInventoryListener {
-
- static val LOG = LoggerFactory.getLogger(NodeChangeCommiter);
-
- @Property
- val FlowCapableInventoryProvider manager;
-
- new(FlowCapableInventoryProvider manager) {
- _manager = manager;
- }
-
- override onNodeConnectorRemoved(NodeConnectorRemoved connector) {
- val ref = connector.nodeConnectorRef;
-
- // Check path
- val it = manager.startChange()
-
- LOG.debug("removing node connector : " + ref.value.toString());
-
- removeOperationalData(ref.value as InstanceIdentifier<? extends DataObject>);
- commit()
- }
-
- override onNodeConnectorUpdated(NodeConnectorUpdated connector) {
- val ref = connector.nodeConnectorRef;
-
- val flowConnector = connector.getAugmentation(FlowCapableNodeConnectorUpdated);
-
- val it = manager.startChange()
- val data = new NodeConnectorBuilder(connector);
- data.key = (new NodeConnectorKey(connector.id))
- if (flowConnector != null) {
- val augment = flowConnector.toInventoryAugment()
- data.addAugmentation(FlowCapableNodeConnector, augment)
- }
-
- LOG.debug("updating node connector : " + ref.value.toString());
-
- putOperationalData(ref.value as InstanceIdentifier<NodeConnector>, data.build());
- commit()
- }
-
- override onNodeRemoved(NodeRemoved node) {
- val ref = node.nodeRef;
- val it = manager.startChange()
-
- LOG.debug("removing node : " + ref.value.toString());
-
- removeOperationalData(ref.value as InstanceIdentifier<? extends DataObject>);
- commit()
- }
-
- override onNodeUpdated(NodeUpdated node) {
- val ref = node.nodeRef;
- val flowNode = node.getAugmentation(FlowCapableNodeUpdated);
-
- val it = manager.startChange()
- val data = new NodeBuilder(node);
- data.key = (new NodeKey(node.id))
- if (flowNode != null) {
- val augment = flowNode.toInventoryAugment();
- data.addAugmentation(FlowCapableNode, augment)
- }
-
- LOG.debug("updating node : " + ref.value.toString());
-
- putOperationalData(ref.value as InstanceIdentifier<Node>, data.build())
- commit()
- }
-}
+}
\ No newline at end of file