Package org.apache.mina.common

Examples of org.apache.mina.common.IoConnector.connect()

393
394
395
396
397
398
399
400
401
402
403
       
        synchronized( sender.lock )
        {
            synchronized( receiver.lock )
            {
                connector.connect( address, receiver );
               
                sender.lock.wait();
                receiver.lock.wait();
            }
        }
View Full Code Here
67
68
69
70
71
72
73
74
75
76
77
            public void messageReceived(IoSession ioSession, Object object) throws Exception {
                super.messageReceived(ioSession, object);
                /** TODO */
            }
        };
        ConnectFuture future = connector.connect(address, ioHandler, endpoint.getConfig());
        future.join();
        session = future.getSession();
    }

    @Override
View Full Code Here
56
57
58
59
60
61
62
63
64
65
66
            }
        });

        final StringBuffer actual = new StringBuffer();

        ConnectFuture future = connector.connect(new VmPipeAddress(1),
                new IoHandlerAdapter() {

                    public void messageReceived(IoSession session,
                            Object message) throws Exception {
                        actual.append(message);
View Full Code Here
58
59
60
61
62
63
64
65
66
67
68
        SocketAddress addr = createSocketAddress(port);

        IoConnector connector = new SocketConnector();
        IoSession[] sessions = new IoSession[5];
        for (int i = 0; i < sessions.length; i++) {
            ConnectFuture future = connector.connect(new InetSocketAddress(
                    "localhost", port), new IoHandlerAdapter());
            future.join();
            sessions[i] = future.getSession();
            Assert.assertTrue(sessions[i].isConnected());
        }
View Full Code Here
117
118
119
120
121
122
123
124
125
126
127
                actual.append("A");
            }

        });

        ConnectFuture future = connector.connect(new VmPipeAddress(1),
                new IoHandlerAdapter() {
                    public void sessionOpened(IoSession session)
                            throws Exception {
                        session.write("B");
                    }
View Full Code Here
51
52
53
54
55
56
57
58
59
60
61
       
        try
        {
            final StringBuffer buf = new StringBuffer();
            IoConnector connector = createConnector();
            ConnectFuture future = connector.connect(
                    new InetSocketAddress( "localhost", port ),
                    new IoHandlerAdapter()
                    {
                        public void sessionCreated( IoSession session )
                        {
View Full Code Here
88
89
90
91
92
93
94
95
96
97
98
    {
        int port = AvailablePortFinder.getNextAvailable( 1025 );
        final StringBuffer buf = new StringBuffer();

        IoConnector connector = createConnector();
        ConnectFuture future = connector.connect(
                new InetSocketAddress( "localhost", port ),
                new IoHandlerAdapter()
                {
                    public void sessionCreated( IoSession session )
                    {
View Full Code Here
61
62
63
64
65
66
67
68
69
70
71
                    }
                });
       
        final StringBuffer actual = new StringBuffer();
       
        ConnectFuture future = connector.connect(
                new VmPipeAddress( 1 ),
                new IoHandlerAdapter() {

                    public void messageReceived( IoSession session, Object message ) throws Exception
                    {
View Full Code Here
127
128
129
130
131
132
133
134
135
136
137
                        actual.append( "A" );
                    }
                   
                });
       
        ConnectFuture future = connector.connect(
                new VmPipeAddress( 1 ),
                new IoHandlerAdapter() {
                    public void sessionOpened( IoSession session ) throws Exception
                    {
                        session.write("B");
View Full Code Here
64
65
66
67
68
69
70
71
72
73
74
    
        IoConnector connector = new SocketConnector();
        IoSession[] sessions = new IoSession[ 5 ];
        for( int i = 0; i < sessions.length; i++ )
        {
            ConnectFuture future = connector.connect( new InetSocketAddress( "localhost", port ), new IoHandlerAdapter() );
            future.join();
            sessions[ i ] = future.getSession();
            Assert.assertTrue( sessions[ i ].isConnected() );
        }
       
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.