2 * Copyright (c) 2016 Cisco Systems, Inc. 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.netconf.server.osgi;
10 import static java.util.Objects.requireNonNull;
12 import java.util.Optional;
13 import java.util.concurrent.ScheduledExecutorService;
14 import java.util.concurrent.TimeUnit;
15 import org.opendaylight.netconf.server.api.monitoring.NetconfMonitoringService;
16 import org.opendaylight.netconf.server.api.monitoring.SessionListener;
17 import org.opendaylight.netconf.server.api.notifications.BaseNotificationPublisherRegistration;
18 import org.opendaylight.netconf.server.api.operations.NetconfOperationServiceFactory;
19 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.netconf.monitoring.rev101004.netconf.state.Capabilities;
20 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.netconf.monitoring.rev101004.netconf.state.Schemas;
21 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.netconf.monitoring.rev101004.netconf.state.Sessions;
22 import org.opendaylight.yangtools.concepts.Registration;
24 public class NetconfMonitoringServiceImpl implements NetconfMonitoringService, AutoCloseable {
25 private final NetconfCapabilityMonitoringService capabilityMonitoring;
26 private final NetconfSessionMonitoringService sessionMonitoring;
28 private NetconfMonitoringServiceImpl(final NetconfOperationServiceFactory opProvider,
29 final NetconfSessionMonitoringService sessionMonitoring) {
30 capabilityMonitoring = new NetconfCapabilityMonitoringService(opProvider);
31 this.sessionMonitoring = requireNonNull(sessionMonitoring);
34 public NetconfMonitoringServiceImpl(final NetconfOperationServiceFactory opProvider) {
35 this(opProvider, new NetconfSessionMonitoringService.WithoutUpdates());
38 public NetconfMonitoringServiceImpl(final NetconfOperationServiceFactory opProvider,
39 final ScheduledExecutorService threadPool, final long periodSeconds) {
40 this(opProvider, periodSeconds > 0
41 ? new NetconfSessionMonitoringService.WithUpdates(threadPool, periodSeconds, TimeUnit.SECONDS)
42 : new NetconfSessionMonitoringService.WithoutUpdates());
46 public Sessions getSessions() {
47 return sessionMonitoring.getSessions();
51 public SessionListener getSessionListener() {
52 return sessionMonitoring;
56 public Schemas getSchemas() {
57 return capabilityMonitoring.getSchemas();
61 public String getSchemaForCapability(final String moduleName, final Optional<String> revision) {
62 return capabilityMonitoring.getSchemaForModuleRevision(moduleName, revision);
66 public Capabilities getCapabilities() {
67 return capabilityMonitoring.getCapabilities();
71 public Registration registerCapabilitiesListener(final CapabilitiesListener listener) {
72 return capabilityMonitoring.registerListener(listener);
76 public Registration registerSessionsListener(final SessionsListener listener) {
77 return sessionMonitoring.registerListener(listener);
80 public void setNotificationPublisher(final BaseNotificationPublisherRegistration notificationPublisher) {
81 capabilityMonitoring.setNotificationPublisher(notificationPublisher);
86 capabilityMonitoring.close();
87 sessionMonitoring.close();