Package org.apache.mina.transport.socket.nio

Examples of org.apache.mina.transport.socket.nio.NioSocketConnector

37
38
39
40
41
42
43
44
45
46
47
        thread.start();
        Thread.sleep( 500 );
       
        client = new MinaTaskClient( "client 1",
                                     new TaskClientHandler(SystemEventListenerFactory.getSystemEventListener()) );
        NioSocketConnector connector = new NioSocketConnector();
        SocketAddress address = new InetSocketAddress( "127.0.0.1",
                                                       9123 );
        client.connect( connector,
                        address );
    }
View Full Code Here
53
54
55
56
57
58
59
60
61
62
63
            throw new IllegalArgumentException( "Address cannot be null" );
        }
        
        if ( this.connector == null ) {
            // Allow users to pass their own configured SocketConnector
            this.connector = new NioSocketConnector();
            this.connector.getFilterChain().addLast( "codec",
                                                     new ProtocolCodecFilter(new ObjectSerializationCodecFactory() ) );
        }

        //        this.handler = new MessageHandler() {
View Full Code Here
32
33
34
35
36
37
38
39
40
41
42
        thread.start();
        Thread.sleep( 500 );

        client = new MinaTaskClient( "client 1",
                                     new TaskClientHandler(SystemEventListenerFactory.getSystemEventListener()) );
        NioSocketConnector connector = new NioSocketConnector();
        SocketAddress address = new InetSocketAddress( "127.0.0.1",
                                                       9123 );
        client.connect( connector,
                        address );
    }
View Full Code Here
42
43
44
45
46
47
48
49
50
51
        server = new MinaTaskServer(taskService);
        Thread thread = new Thread(server);
        thread.start();
        Thread.sleep(500);
        client = new MinaTaskClient("client 1", new TaskClientHandler(SystemEventListenerFactory.getSystemEventListener()));
        NioSocketConnector connector = new NioSocketConnector();
        SocketAddress address = new InetSocketAddress("127.0.0.1", 9123);
        client.connect(connector, address);
        handler = new WSHumanTaskHandler();
    }
View Full Code Here
34
35
36
37
38
39
40
41
42
43
44
        thread.start();
        Thread.sleep( 500 );
       
        client = new MinaTaskClient( "client 1",
                                     new TaskClientHandler(SystemEventListenerFactory.getSystemEventListener()) );
        NioSocketConnector connector = new NioSocketConnector();
        SocketAddress address = new InetSocketAddress( "127.0.0.1",
                                                       9123 );
        client.connect( connector,
                        address );
       
View Full Code Here
32
33
34
35
36
37
38
39
40
41
42
        thread.start();
        Thread.sleep( 500 );

        client = new MinaTaskClient( "client 1",
                                     new TaskClientHandler(SystemEventListenerFactory.getSystemEventListener()) );
        NioSocketConnector connector = new NioSocketConnector();
        SocketAddress address = new InetSocketAddress( "127.0.0.1",
                                                       9123 );
        client.connect( connector,
                        address );
    }
View Full Code Here
58
59
60
61
62
63
64
65
66
67
68
 
  public void connect() {
    if (client == null) {
      client = new MinaTaskClient(
        "org.drools.process.workitem.wsht.WSHumanTaskHandler", new TaskClientHandler());
      NioSocketConnector connector = new NioSocketConnector();
      SocketAddress address = new InetSocketAddress(ipAddress, port);
      boolean connected = client.connect(connector, address);
      if (!connected) {
        throw new IllegalArgumentException(
          "Could not connect task client");
View Full Code Here
55
56
57
58
59
60
61
62
63
64
        this.connector.setHandler( this.handler );
        return connect();
    }

  public boolean connect(String address, int port) {
    this.connector = new NioSocketConnector();
        this.address = new InetSocketAddress( address, port );
        this.connector.setHandler( this.handler );
        return connect();
  }
View Full Code Here
68
69
70
71
72
73
74
75
76
77
78
            throw new IllegalStateException(
                    "Already connected. Disconnect first.");
        }

        if (this.connector==null) {
          this.connector = new NioSocketConnector();
        }
       
        if (this.address==null) {
          this.address = new InetSocketAddress( "127.0.0.1", 9123);
        }
View Full Code Here
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
            System.out.println(Main.class.getName() + " <hostname> <port>");
            return;
        }

        // Create TCP/IP connector.
        NioSocketConnector connector = new NioSocketConnector();

        // Set connect timeout.
        connector.setConnectTimeout(30);

        // Start communication.
        connector.setHandler(new NetCatProtocolHandler());
        ConnectFuture cf = connector.connect(
                new InetSocketAddress(args[0], Integer.parseInt(args[1])));

        // Wait for the connection attempt to be finished.
        cf.awaitUninterruptibly();
        cf.getSession().getCloseFuture().awaitUninterruptibly();
       
        connector.dispose();
    }
View Full Code Here
TOP

Related Classes of org.apache.mina.transport.socket.nio.NioSocketConnector

  • asia.stampy.client.mina.ClientMinaMessageGateway
  • com.akdeniz.googleplaycrawler.gsf.MTalkConnector
  • com.notnoop.apns.internal.MinaAdaptor
  • com.starlight.intrepid.spi.mina.MINAIntrepidSPI
  • com.zhangwoo.spider.client.process.ClientMessageCenter
  • devutilsplugin.utils.SocketClient
  • net.solosky.maplefetion.net.mina.MinaTransferFactory
  • org.adbcj.mysql.mina.MysqlConnectionManager
  • org.adbcj.postgresql.mina.MinaConnectionManager
  • org.apache.camel.component.mina2.Mina2Producer
    • Copyright © 2018 www.massapicom. 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.