2 * Copyright © 2017 AT&T and others. All rights reserved.
4 * This program and the accompanying materials are made available under the
5 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6 * and is available at http://www.eclipse.org/legal/epl-v10.html
8 package org.opendaylight.transportpce.inventory;
10 import javax.sql.DataSource;
11 import org.opendaylight.mdsal.binding.api.DataBroker;
12 import org.opendaylight.mdsal.binding.api.DataTreeChangeListener;
13 import org.opendaylight.mdsal.binding.api.DataTreeIdentifier;
14 import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
15 import org.opendaylight.transportpce.common.InstanceIdentifiers;
16 import org.opendaylight.transportpce.common.device.DeviceTransactionManager;
17 import org.opendaylight.transportpce.inventory.listener.ClliNetworkChangeListener;
18 import org.opendaylight.transportpce.inventory.listener.DeviceConfigListener;
19 import org.opendaylight.transportpce.inventory.listener.DeviceListener;
20 import org.opendaylight.transportpce.inventory.listener.OverlayNetworkChangeListener;
21 import org.opendaylight.transportpce.inventory.listener.UnderlayNetworkChangeListener;
22 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node;
23 import org.osgi.service.component.annotations.Activate;
24 import org.osgi.service.component.annotations.Component;
25 import org.osgi.service.component.annotations.Reference;
26 import org.slf4j.Logger;
27 import org.slf4j.LoggerFactory;
30 * {@link ListenerProvider} registers {@link DataTreeChangeListener} for each network layer.
33 public class ListenerProvider {
35 private static final Logger LOG = LoggerFactory.getLogger(ListenerProvider.class);
38 * Constructor invoked by blueprint injects all dependencies.
40 * @param dataBroker dataBroker
41 * @param dataSource dataSource
42 * @param deviceTransactionManager deviceTransactionManager
45 public ListenerProvider(@Reference DataBroker dataBroker,
46 @Reference DataSource dataSource,
47 @Reference DeviceTransactionManager deviceTransactionManager) {
49 LOG.debug("Registering listeners...");
50 OverlayNetworkChangeListener overlayNetworkListener = new OverlayNetworkChangeListener();
51 dataBroker.registerDataTreeChangeListener(
52 DataTreeIdentifier.create(LogicalDatastoreType.CONFIGURATION, InstanceIdentifiers.OVERLAY_NETWORK_II),
53 overlayNetworkListener);
54 LOG.info("Overlay network change listener was successfully registered");
55 UnderlayNetworkChangeListener underlayNetworkListener = new UnderlayNetworkChangeListener();
56 dataBroker.registerDataTreeChangeListener(
57 DataTreeIdentifier.create(LogicalDatastoreType.CONFIGURATION, InstanceIdentifiers.UNDERLAY_NETWORK_II),
58 underlayNetworkListener);
59 LOG.info("Underlay network change listener was successfully registered");
60 ClliNetworkChangeListener clliNetworkChangeListener = new ClliNetworkChangeListener();
61 dataBroker.registerDataTreeChangeListener(
62 DataTreeIdentifier.create(LogicalDatastoreType.CONFIGURATION, InstanceIdentifiers.CLLI_NETWORK_II),
63 clliNetworkChangeListener);
64 LOG.info("CLLI network change listener was successfully registered");
65 INode121 inode121 = new INode121(dataSource, deviceTransactionManager);
66 INode inode = new INode(dataSource, inode121);
67 DeviceInventory deviceInventory = new DeviceInventory(dataSource, inode);
68 DeviceListener deviceListener = new DeviceListener(deviceInventory);
69 dataBroker.registerDataTreeChangeListener(
70 DataTreeIdentifier.create(LogicalDatastoreType.OPERATIONAL,
71 InstanceIdentifiers.NETCONF_TOPOLOGY_II.child(Node.class)), deviceListener);
72 LOG.info("Device change listener was successfully registered");
73 DeviceConfigListener deviceConfigListener = new DeviceConfigListener(deviceInventory);
74 dataBroker.registerDataTreeChangeListener(
75 DataTreeIdentifier.create(LogicalDatastoreType.CONFIGURATION,
76 InstanceIdentifiers.NETCONF_TOPOLOGY_II.child(Node.class)), deviceConfigListener);
77 LOG.info("Device config change listener was successfully registered");