+++ /dev/null
-/*
- * 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();
- }
-}