HoneyNode Java 11 support for 121 devices

[transportpce.git] / tests / honeynode / 1.2.1 / netconf-impl / src / test / java / org / opendaylight / netconf / impl / NetconfDispatcherImplTest.java

diff --git a/tests/honeynode/1.2.1/netconf-impl/src/test/java/org/opendaylight/netconf/impl/NetconfDispatcherImplTest.java b/tests/honeynode/1.2.1/netconf-impl/src/test/java/org/opendaylight/netconf/impl/NetconfDispatcherImplTest.java
new file mode 100644 (file)
index 0000000..c24aaf8
--- /dev/null
+++ b/tests/honeynode/1.2.1/netconf-impl/src/test/java/org/opendaylight/netconf/impl/NetconfDispatcherImplTest.java
@@ -0,0 +1,65 @@
+/*
+ * Copyright (c) 2013 Cisco Systems, Inc. and others.  All rights reserved.
+ *
+ * This program and the accompanying materials are made available under the
+ * terms of the Eclipse Public License v1.0 which accompanies this distribution,
+ * and is available at http://www.eclipse.org/legal/epl-v10.html
+ */
+
+package org.opendaylight.netconf.impl;
+
+import io.netty.channel.ChannelFuture;
+import io.netty.channel.EventLoopGroup;
+import io.netty.channel.nio.NioEventLoopGroup;
+import io.netty.util.HashedWheelTimer;
+import java.net.InetSocketAddress;
+import org.junit.After;
+import org.junit.Before;
+import org.junit.Test;
+import org.opendaylight.netconf.impl.osgi.AggregatedNetconfOperationServiceFactory;
+
+public class NetconfDispatcherImplTest {
+
+    private EventLoopGroup nettyGroup;
+    private NetconfServerDispatcherImpl dispatch;
+    private HashedWheelTimer hashedWheelTimer;
+
+
+    @Before
+    public void setUp() throws Exception {
+        nettyGroup = new NioEventLoopGroup();
+
+        AggregatedNetconfOperationServiceFactory factoriesListener = new AggregatedNetconfOperationServiceFactory();
+
+        SessionIdProvider idProvider = new SessionIdProvider();
+        hashedWheelTimer = new HashedWheelTimer();
+
+        NetconfServerSessionNegotiatorFactory serverNegotiatorFactory =
+                new NetconfServerSessionNegotiatorFactoryBuilder()
+                        .setAggregatedOpService(factoriesListener)
+                        .setTimer(hashedWheelTimer)
+                        .setIdProvider(idProvider)
+                        .setMonitoringService(ConcurrentClientsTest.createMockedMonitoringService())
+                        .setConnectionTimeoutMillis(5000)
+                        .build();
+
+        NetconfServerDispatcherImpl.ServerChannelInitializer serverChannelInitializer =
+                new NetconfServerDispatcherImpl.ServerChannelInitializer(serverNegotiatorFactory);
+
+        dispatch = new NetconfServerDispatcherImpl(
+                serverChannelInitializer, nettyGroup, nettyGroup);
+    }
+
+    @After
+    public void tearDown() throws Exception {
+        hashedWheelTimer.stop();
+        nettyGroup.shutdownGracefully();
+    }
+
+    @Test
+    public void test() throws Exception {
+        InetSocketAddress addr = new InetSocketAddress("127.0.0.1", 8333);
+        ChannelFuture server = dispatch.createServer(addr);
+        server.get();
+    }
+}