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=0537942487296c19d99ffa2dcc10cea4a64bd6af;hp=afbf80d1e50af0d1d75749b632dd4d0c9d16bedf;hb=399bedb250471fcdca4d5cdb472b7d9f5f6bac76;hpb=8f4996a3a1d486d83907c656a6c5390686c360a1 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 afbf80d1e5..0537942487 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,46 +8,34 @@ package org.opendaylight.controller.netconf.impl; -import org.opendaylight.controller.netconf.api.NetconfOperationRouter; import org.opendaylight.controller.netconf.impl.mapping.CapabilityProvider; +import org.opendaylight.controller.netconf.impl.osgi.NetconfOperationRouter; import org.opendaylight.controller.netconf.impl.osgi.NetconfOperationRouterImpl; import org.opendaylight.controller.netconf.impl.osgi.SessionMonitoringService; -import org.opendaylight.controller.netconf.mapping.api.NetconfOperationProvider; import org.opendaylight.controller.netconf.mapping.api.NetconfOperationServiceSnapshot; import org.opendaylight.protocol.framework.SessionListenerFactory; -import static org.opendaylight.controller.netconf.mapping.api.NetconfOperationProvider.NetconfOperationProviderUtil.getNetconfSessionIdForReporting; - public class NetconfServerSessionListenerFactory implements SessionListenerFactory { - private final NetconfOperationProvider netconfOperationProvider; - private final DefaultCommitNotificationProducer commitNotifier; - - private final SessionIdProvider idProvider; - private final SessionMonitoringService monitor; + private final NetconfOperationServiceSnapshot netconfOperationServiceSnapshot; + private final CapabilityProvider capabilityProvider; + + public NetconfServerSessionListenerFactory(final DefaultCommitNotificationProducer commitNotifier, + final SessionMonitoringService monitor, + final NetconfOperationServiceSnapshot netconfOperationServiceSnapshot, + final CapabilityProvider capabilityProvider) { - public NetconfServerSessionListenerFactory(NetconfOperationProvider netconfOperationProvider, - DefaultCommitNotificationProducer commitNotifier, - SessionIdProvider idProvider, SessionMonitoringService monitor) { - this.netconfOperationProvider = netconfOperationProvider; this.commitNotifier = commitNotifier; - this.idProvider = idProvider; this.monitor = monitor; + this.netconfOperationServiceSnapshot = netconfOperationServiceSnapshot; + this.capabilityProvider = capabilityProvider; } @Override public NetconfServerSessionListener getSessionListener() { - NetconfOperationServiceSnapshot netconfOperationServiceSnapshot = netconfOperationProvider.getSnapshot( - getNetconfSessionIdForReporting(idProvider.getCurrentSessionId())); - - CapabilityProvider capabilityProvider = new CapabilityProviderImpl(netconfOperationServiceSnapshot); - - NetconfOperationRouter operationRouter = NetconfOperationRouterImpl.createOperationRouter( - netconfOperationServiceSnapshot, capabilityProvider, - commitNotifier); - - return new NetconfServerSessionListener(operationRouter, monitor); + NetconfOperationRouter operationRouter = new NetconfOperationRouterImpl(netconfOperationServiceSnapshot, capabilityProvider, commitNotifier); + return new NetconfServerSessionListener(operationRouter, monitor, netconfOperationServiceSnapshot); } }