Package org.apache.mina.common

Examples of org.apache.mina.common.IoAcceptor.bind()

45
46
47
48
49
50
51
52
53
54
55
   
    public void testConnectFutureSuccessTiming() throws Exception
    {
        int port = AvailablePortFinder.getNextAvailable( 1025 );
        IoAcceptor acceptor = createAcceptor();
        acceptor.bind( new InetSocketAddress( port ), new IoHandlerAdapter() );
       
        try
        {
            final StringBuffer buf = new StringBuffer();
            IoConnector connector = createConnector();
View Full Code Here
45
46
47
48
49
50
51
52
53
54
55
        IoConnector connector = new VmPipeConnector();
        connector.getDefaultConfig().setThreadModel( ThreadModel.MANUAL );
        //connector.getFilterChain().addLast( "logger", new LoggingFilter() );
       
        acceptor.bind(
                new VmPipeAddress( 1 ),
                new IoHandlerAdapter() {
                    public void sessionOpened( IoSession session ) throws Exception
                    {
                        session.write("B");
View Full Code Here
107
108
109
110
111
112
113
114
115
116
117
        connector.getDefaultConfig().setThreadModel( ThreadModel.MANUAL );
        //connector.getFilterChain().addLast( "logger", new LoggingFilter() );
       
        final StringBuffer actual = new StringBuffer();
       
        acceptor.bind(
                new VmPipeAddress( 1 ),
                new IoHandlerAdapter() {

                    public void messageReceived( IoSession session, Object message ) throws Exception
                    {
View Full Code Here
60
61
62
63
64
65
66
67
68
69
70
                    "codec",
                    new ProtocolCodecFilter( new ObjectSerializationCodecFactory() ) );
        }
        cfg.getFilterChain().addLast( "logger", new LoggingFilter() );

        acceptor.bind(
                new InetSocketAddress( SERVER_PORT ),
                new ServerSessionHandler( ), cfg );

        System.out.println( "Listening on port " + SERVER_PORT );
    }
View Full Code Here
87
88
89
90
91
92
93
94
95
96
97
            String host = InetAddress.getLocalHost().getHostName();
            ClusteredProtocolHandler handler = new ClusteredProtocolHandler(new InetSocketAddress(host, port));
            if (!connectorConfig.enableSSL)
            {
                acceptor.bind(new InetSocketAddress(port), handler, sconfig);
                _logger.info("Qpid.AMQP listening on non-SSL port " + port);
                handler.connect(commandLine.getOptionValue("j"));
            }
            else
            {
View Full Code Here
94
95
96
97
98
99
100
101
102
103
104
                handler.connect(commandLine.getOptionValue("j"));
            }
            else
            {
                ClusteredProtocolHandler sslHandler = new ClusteredProtocolHandler(handler);
                acceptor.bind(new InetSocketAddress(connectorConfig.sslPort), sslHandler, sconfig);
                _logger.info("Qpid.AMQP listening on SSL port " + connectorConfig.sslPort);
            }
        }
        catch (IOException e)
        {
View Full Code Here
47
48
49
50
51
52
53
54
55
56
57
        IoServiceConfig config2 =
            ( IoServiceConfig ) MockControl.createControl( IoServiceConfig.class ).getMock();
        MockControl mockIoAcceptor = MockControl.createControl( IoAcceptor.class );
        IoAcceptor acceptor = ( IoAcceptor ) mockIoAcceptor.getMock();
       
        acceptor.bind( new InetSocketAddress( 80 ), handler1, config1 );
        acceptor.bind( new InetSocketAddress( "192.168.0.1", 22 ), handler2, config2 );
        acceptor.bind( new InetSocketAddress( "10.0.0.1", 9876 ), handler3 );
        acceptor.unbind( new InetSocketAddress( 80 ) );
        acceptor.unbind( new InetSocketAddress( "192.168.0.1", 22 ) );
        acceptor.unbind( new InetSocketAddress( "10.0.0.1", 9876 ) );
View Full Code Here
48
49
50
51
52
53
54
55
56
57
58
            ( IoServiceConfig ) MockControl.createControl( IoServiceConfig.class ).getMock();
        MockControl mockIoAcceptor = MockControl.createControl( IoAcceptor.class );
        IoAcceptor acceptor = ( IoAcceptor ) mockIoAcceptor.getMock();
       
        acceptor.bind( new InetSocketAddress( 80 ), handler1, config1 );
        acceptor.bind( new InetSocketAddress( "192.168.0.1", 22 ), handler2, config2 );
        acceptor.bind( new InetSocketAddress( "10.0.0.1", 9876 ), handler3 );
        acceptor.unbind( new InetSocketAddress( 80 ) );
        acceptor.unbind( new InetSocketAddress( "192.168.0.1", 22 ) );
        acceptor.unbind( new InetSocketAddress( "10.0.0.1", 9876 ) );
       
View Full Code Here
49
50
51
52
53
54
55
56
57
58
59
        MockControl mockIoAcceptor = MockControl.createControl( IoAcceptor.class );
        IoAcceptor acceptor = ( IoAcceptor ) mockIoAcceptor.getMock();
       
        acceptor.bind( new InetSocketAddress( 80 ), handler1, config1 );
        acceptor.bind( new InetSocketAddress( "192.168.0.1", 22 ), handler2, config2 );
        acceptor.bind( new InetSocketAddress( "10.0.0.1", 9876 ), handler3 );
        acceptor.unbind( new InetSocketAddress( 80 ) );
        acceptor.unbind( new InetSocketAddress( "192.168.0.1", 22 ) );
        acceptor.unbind( new InetSocketAddress( "10.0.0.1", 9876 ) );
       
        mockIoAcceptor.replay();
View Full Code Here
47
48
49
50
51
52
53
54
55
56
57
        final AtomicReference c1 = new AtomicReference();
        final CountDownLatch latch = new CountDownLatch( 1 );
        final CountDownLatch messageCount = new CountDownLatch( 2 );
        IoAcceptor acceptor = new VmPipeAcceptor();

        acceptor.bind( address, new IoHandlerAdapter() {
            public void messageReceived( IoSession session, Object message ) throws Exception {
                System.out.println( Thread.currentThread().getName() + ": " + message );

                if ( "start".equals( message ) ) {
                    session.write( "open new" );
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.