Package ch.unifr.nio.framework.mockups

Examples of ch.unifr.nio.framework.mockups.TestTarget.start()

39
40
41
42
43
44
45
46
47
48
49
        consoleHandler.setLevel(Level.FINEST);
        logger.addHandler(consoleHandler);
        SteppingDispatcher steppingDispatcher = new SteppingDispatcher();
        steppingDispatcher.start();
        TestTarget testTarget = new TestTarget(12345);
        testTarget.start();
        SocketChannel channel = testTarget.getSocketChannel();
        BlockingSocketChannel blockingChannel =
                new BlockingSocketChannel(channel);
        blockingChannel.configureBlocking(false);
        TestChannelHandler testChannelHandler = new TestChannelHandler();
View Full Code Here
45
46
47
48
49
50
51
52
53
54
55
        Selector selector = Selector.open();

        LOGGER.finest("starting TestTarget");
        TestTarget testTarget = new TestTarget(11111);
        testTarget.start();
        SocketChannel socketChannel = testTarget.getSocketChannel();
        Thread.sleep(1000);

        LOGGER.finest("configure non-blocking");
        socketChannel.configureBlocking(false);
View Full Code Here
34
35
36
37
38
39
40
41
42
43
44
        Dispatcher dispatcher = new Dispatcher();
        dispatcher.start();

        // prepare target 1
        TestTarget target1 = new TestTarget(11111);
        target1.start();
        SocketChannel channel1 = target1.getSocketChannel();
        channel1.configureBlocking(false);
        TestChannelHandler handler1 = new TestChannelHandler();
        handler1.setInputHandling(TestChannelHandler.InputHandling.FORWARD);
        dispatcher.registerChannel(channel1, handler1);
View Full Code Here
43
44
45
46
47
48
49
50
51
52
53
        handler1.setInputHandling(TestChannelHandler.InputHandling.FORWARD);
        dispatcher.registerChannel(channel1, handler1);

        // prepare target 2
        TestTarget target2 = new TestTarget(22222);
        target2.start();
        SocketChannel channel2 = target2.getSocketChannel();
        channel2.configureBlocking(false);
        TestChannelHandler handler2 = new TestChannelHandler();
        handler2.setInputHandling(TestChannelHandler.InputHandling.FORWARD);
        dispatcher.registerChannel(channel2, handler2);
View Full Code Here
37
38
39
40
41
42
43
44
45
46
47
        consoleHandler.setLevel(Level.FINEST);
        logger.addHandler(consoleHandler);
        SteppingDispatcher steppingDispatcher = new SteppingDispatcher();
        steppingDispatcher.start();
        TestTarget testTarget = new TestTarget(12345);
        testTarget.start();
        SocketChannel channel = testTarget.getSocketChannel();
        BlockingSocketChannel blockingChannel =
                new BlockingSocketChannel(channel);
        blockingChannel.configureBlocking(false);
        TestChannelHandler testChannelHandler = new TestChannelHandler();
View Full Code Here
49
50
51
52
53
54
55
56
57
58
59
        consoleHandler.setLevel(Level.FINEST);
        logger.addHandler(consoleHandler);
        CacheStopDispatcher cacheStopDispatcher = new CacheStopDispatcher();
        cacheStopDispatcher.start();
        TestTarget testTarget = new TestTarget(12345);
        testTarget.start();
        SocketChannel channel = testTarget.getSocketChannel();
        BlockingSocketChannel blockingChannel = new BlockingSocketChannel(channel);
        blockingChannel.configureBlocking(false);
        final TestChannelHandler testChannelHandler = new TestChannelHandler();
        cacheStopDispatcher.registerChannel(blockingChannel, testChannelHandler);
View Full Code Here
29
30
31
32
33
34
35
36
37
38
39
        dispatcher.start();

        // start a dummy target
        final int PORT = 11111;
        TestTarget testTarget = new TestTarget(PORT);
        testTarget.start();
        testTarget.getSocketChannel();

        MyClientSocketChannelHandler handler =
                new MyClientSocketChannelHandler();
        dispatcher.registerClientSocketChannelHandler(
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.