X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fnetconf%2Fnetconf-impl%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fnetconf%2Fimpl%2FNetconfDispatcherImplTest.java;h=0ecc1cb38324ede5b3443706a071a68a3d21a9dc;hp=e43febec793f6ad43029169ed083c7ede7f22a4d;hb=91d7c1ee52322acad08e9f81228ac36b3aa684f5;hpb=794febd19b059e2b9f2c32f9b6bc26c3996cb14e diff --git a/opendaylight/netconf/netconf-impl/src/test/java/org/opendaylight/controller/netconf/impl/NetconfDispatcherImplTest.java b/opendaylight/netconf/netconf-impl/src/test/java/org/opendaylight/controller/netconf/impl/NetconfDispatcherImplTest.java index e43febec79..0ecc1cb383 100644 --- a/opendaylight/netconf/netconf-impl/src/test/java/org/opendaylight/controller/netconf/impl/NetconfDispatcherImplTest.java +++ b/opendaylight/netconf/netconf-impl/src/test/java/org/opendaylight/controller/netconf/impl/NetconfDispatcherImplTest.java @@ -8,7 +8,6 @@ package org.opendaylight.controller.netconf.impl; -import com.google.common.base.Optional; import io.netty.channel.ChannelFuture; import io.netty.channel.EventLoopGroup; import io.netty.channel.nio.NioEventLoopGroup; @@ -19,28 +18,20 @@ import org.junit.Test; import org.opendaylight.controller.netconf.impl.osgi.NetconfOperationServiceFactoryListener; import org.opendaylight.controller.netconf.impl.osgi.NetconfOperationServiceFactoryListenerImpl; -import javax.net.ssl.SSLContext; import java.lang.management.ManagementFactory; import java.net.InetSocketAddress; public class NetconfDispatcherImplTest { private EventLoopGroup nettyGroup; + private NetconfServerDispatcher dispatch; + private DefaultCommitNotificationProducer commitNot; @Before public void setUp() throws Exception { nettyGroup = new NioEventLoopGroup(); - } - - @After - public void tearDown() throws Exception { - nettyGroup.shutdownGracefully(); - } - @Test - public void test() throws Exception { - - DefaultCommitNotificationProducer commitNot = new DefaultCommitNotificationProducer( + commitNot = new DefaultCommitNotificationProducer( ManagementFactory.getPlatformMBeanServer()); NetconfOperationServiceFactoryListener factoriesListener = new NetconfOperationServiceFactoryListenerImpl(); @@ -49,16 +40,23 @@ public class NetconfDispatcherImplTest { new HashedWheelTimer(), factoriesListener, idProvider); NetconfServerSessionListenerFactory listenerFactory = new NetconfServerSessionListenerFactory( - factoriesListener, commitNot, idProvider); - NetconfServerDispatcher.ServerSslChannelInitializer serverChannelInitializer = new NetconfServerDispatcher.ServerSslChannelInitializer(Optional.absent(), serverNegotiatorFactory, listenerFactory); + factoriesListener, commitNot, idProvider, null); + NetconfServerDispatcher.ServerChannelInitializer serverChannelInitializer = new NetconfServerDispatcher.ServerChannelInitializer(serverNegotiatorFactory, listenerFactory); - - NetconfServerDispatcher dispatch = new NetconfServerDispatcher( + dispatch = new NetconfServerDispatcher( serverChannelInitializer, nettyGroup, nettyGroup); + } + @After + public void tearDown() throws Exception { + commitNot.close(); + nettyGroup.shutdownGracefully(); + } + + @Test + public void test() throws Exception { InetSocketAddress addr = new InetSocketAddress("127.0.0.1", 8333); ChannelFuture s = dispatch.createServer(addr); - - commitNot.close(); + s.get(); } }