opendaylight/netconf/mdsal-netconf-notification/src/main/java/org/opendaylight/controller/config/yang/netconf/mdsal/notification/NetconfMdsalNotificationMapperModule.java

   1 /*
   2  * Copyright (c) 2015 Cisco Systems, Inc. and others.  All rights reserved.
   3  *
   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
   7  */
   8
   9 package org.opendaylight.controller.config.yang.netconf.mdsal.notification;
  10
  11 import org.opendaylight.controller.md.sal.common.api.data.AsyncDataBroker;
  12 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
  13 import org.opendaylight.netconf.mdsal.notification.NetconfNotificationOperationServiceFactory;
  14 import org.opendaylight.netconf.notifications.NetconfNotificationCollector;
  15 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.netconf.monitoring.rev101004.NetconfState;
  16 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.netconf.monitoring.rev101004.netconf.state.Capabilities;
  17 import org.opendaylight.yangtools.concepts.ListenerRegistration;
  18 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  19
  20 public class NetconfMdsalNotificationMapperModule extends org.opendaylight.controller.config.yang.netconf.mdsal.notification.AbstractNetconfMdsalNotificationMapperModule {
  21     public NetconfMdsalNotificationMapperModule(org.opendaylight.controller.config.api.ModuleIdentifier identifier, org.opendaylight.controller.config.api.DependencyResolver dependencyResolver) {
  22         super(identifier, dependencyResolver);
  23     }
  24
  25     public NetconfMdsalNotificationMapperModule(org.opendaylight.controller.config.api.ModuleIdentifier identifier, org.opendaylight.controller.config.api.DependencyResolver dependencyResolver, org.opendaylight.controller.config.yang.netconf.mdsal.notification.NetconfMdsalNotificationMapperModule oldModule, java.lang.AutoCloseable oldInstance) {
  26         super(identifier, dependencyResolver, oldModule, oldInstance);
  27     }
  28
  29     @Override
  30     public void customValidation() {
  31         // add custom validation form module attributes here.
  32     }
  33
  34     @Override
  35     public java.lang.AutoCloseable createInstance() {
  36         final NetconfNotificationCollector notificationCollector = getNotificationCollectorDependency();
  37
  38         final NotificationToMdsalWriter notificationToMdsalWriter = new NotificationToMdsalWriter(notificationCollector);
  39         getBindingAwareBrokerDependency().registerProvider(notificationToMdsalWriter);
  40
  41         InstanceIdentifier capabilitiesIdentifier = InstanceIdentifier.create(NetconfState.class).child(Capabilities.class).builder().build();
  42
  43         final ListenerRegistration capabilityChangeListenerRegistration = getDataBrokerDependency().registerDataChangeListener(LogicalDatastoreType.OPERATIONAL, capabilitiesIdentifier,
  44                 new BaseCapabilityChangeNotificationPublisher(notificationCollector.registerBaseNotificationPublisher()), AsyncDataBroker.DataChangeScope.SUBTREE);
  45
  46         final NetconfNotificationOperationServiceFactory netconfNotificationOperationServiceFactory =
  47             new NetconfNotificationOperationServiceFactory(getNotificationRegistryDependency()) {
  48                 @Override
  49                 public void close() {
  50                     super.close();
  51                     notificationToMdsalWriter.close();
  52                     capabilityChangeListenerRegistration.close();
  53                     getAggregatorDependency().onRemoveNetconfOperationServiceFactory(this);
  54                 }
  55             };
  56
  57         getAggregatorDependency().onAddNetconfOperationServiceFactory(netconfNotificationOperationServiceFactory);
  58
  59         return netconfNotificationOperationServiceFactory;
  60     }
  61 }