X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fnetconf%2Fnetconf-impl%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fnetconf%2Fimpl%2FNetconfServerSessionListenerFactory.java;h=34a8bc4fd57f7a670aad66aa68cc824bf2905572;hp=70ddf299fd5dd0d7ff8c091598c0644a88278342;hb=9c9d6e69da3aff2d0576d8c15ea0fa0692595b6d;hpb=9108efddf9a5f3e2c81202a17ccdeca22cb5ca09 diff --git a/opendaylight/netconf/netconf-impl/src/main/java/org/opendaylight/controller/netconf/impl/NetconfServerSessionListenerFactory.java b/opendaylight/netconf/netconf-impl/src/main/java/org/opendaylight/controller/netconf/impl/NetconfServerSessionListenerFactory.java index 70ddf299fd..34a8bc4fd5 100644 --- a/opendaylight/netconf/netconf-impl/src/main/java/org/opendaylight/controller/netconf/impl/NetconfServerSessionListenerFactory.java +++ b/opendaylight/netconf/netconf-impl/src/main/java/org/opendaylight/controller/netconf/impl/NetconfServerSessionListenerFactory.java @@ -8,39 +8,35 @@ package org.opendaylight.controller.netconf.impl; +import org.opendaylight.controller.netconf.impl.osgi.NetconfOperationRouter; import org.opendaylight.controller.netconf.impl.mapping.CapabilityProvider; import org.opendaylight.controller.netconf.impl.osgi.NetconfOperationRouterImpl; -import org.opendaylight.controller.netconf.impl.osgi.NetconfOperationServiceFactoryListener; -import org.opendaylight.controller.netconf.impl.osgi.NetconfOperationServiceSnapshot; +import org.opendaylight.controller.netconf.impl.osgi.SessionMonitoringService; +import org.opendaylight.controller.netconf.mapping.api.NetconfOperationServiceSnapshot; import org.opendaylight.protocol.framework.SessionListenerFactory; public class NetconfServerSessionListenerFactory implements SessionListenerFactory { - private final NetconfOperationServiceFactoryListener factoriesListener; - private final DefaultCommitNotificationProducer commitNotifier; + private final SessionMonitoringService monitor; + private final NetconfOperationServiceSnapshot netconfOperationServiceSnapshot; + private final CapabilityProvider capabilityProvider; - private final SessionIdProvider idProvider; + public NetconfServerSessionListenerFactory(DefaultCommitNotificationProducer commitNotifier, + SessionMonitoringService monitor, + NetconfOperationServiceSnapshot netconfOperationServiceSnapshot, + CapabilityProvider capabilityProvider) { - public NetconfServerSessionListenerFactory(NetconfOperationServiceFactoryListener factoriesListener, - DefaultCommitNotificationProducer commitNotifier, - SessionIdProvider idProvider) { - this.factoriesListener = factoriesListener; this.commitNotifier = commitNotifier; - this.idProvider = idProvider; + this.monitor = monitor; + this.netconfOperationServiceSnapshot = netconfOperationServiceSnapshot; + this.capabilityProvider = capabilityProvider; } @Override public NetconfServerSessionListener getSessionListener() { - NetconfOperationServiceSnapshot netconfOperationServiceSnapshot = factoriesListener.getSnapshot(idProvider - .getCurrentSessionId()); - - CapabilityProvider capabilityProvider = new CapabilityProviderImpl(netconfOperationServiceSnapshot); - - NetconfOperationRouterImpl operationRouter = new NetconfOperationRouterImpl( - netconfOperationServiceSnapshot, capabilityProvider, - commitNotifier); - - return new NetconfServerSessionListener(operationRouter); + NetconfOperationRouter operationRouter = NetconfOperationRouterImpl.createOperationRouter( + netconfOperationServiceSnapshot, capabilityProvider, commitNotifier); + return new NetconfServerSessionListener(operationRouter, monitor, netconfOperationServiceSnapshot); } }