Package org.jboss.netty.channel

Examples of org.jboss.netty.channel.ChannelFuture.awaitUninterruptibly()

68
69
70
71
72
73
74
75
76
77
78
  {
    ChannelFuture connectFuture = _clientBootstrap.connect(serverAddress);
    if (_timeoutPolicy == TimeoutPolicy.CONNECT_TIMEOUT ||
        _timeoutPolicy == TimeoutPolicy.ALL_TIMEOUTS)
    {
      connectFuture.awaitUninterruptibly(1000, TimeUnit.SECONDS);
    }
    else
    {
      connectFuture.awaitUninterruptibly();
    }
View Full Code Here
72
73
74
75
76
77
78
79
80
81
82
    {
      connectFuture.awaitUninterruptibly(1000, TimeUnit.SECONDS);
    }
    else
    {
      connectFuture.awaitUninterruptibly();
    }
    assertTrue("connect succeeded", connectFuture.isSuccess());

    Channel requestChannel = connectFuture.getChannel();
    ChannelFuture writeFuture = requestChannel.write(request);
View Full Code Here
82
83
84
85
86
87
88
89
90
91
92
    ChannelFuture writeFuture = requestChannel.write(request);

    if (_timeoutPolicy == TimeoutPolicy.SEND_TIMEOUT ||
        _timeoutPolicy == TimeoutPolicy.ALL_TIMEOUTS)
    {
      writeFuture.awaitUninterruptibly(1000, TimeUnit.SECONDS);
    }
    else
    {
      writeFuture.awaitUninterruptibly();
    }
View Full Code Here
86
87
88
89
90
91
92
93
94
95
96
    {
      writeFuture.awaitUninterruptibly(1000, TimeUnit.SECONDS);
    }
    else
    {
      writeFuture.awaitUninterruptibly();
    }
    assertTrue("send succeeded", writeFuture.isSuccess());

    return _responseHandler;
  }
View Full Code Here
98
99
100
101
102
103
104
105
106
107
108
        if (interrupted) {
            Thread.currentThread().interrupt();
        }

        // Wait for the future.
        future.awaitUninterruptibly();
        if (!future.isSuccess()) {
            future.getChannel().close().awaitUninterruptibly();
            throw new ChannelException("Failed to bind to: " + localAddress, future.getCause());
        }
View Full Code Here
89
90
91
92
93
94
95
96
97
98
99
          }
        }
      }
    });
    // Wait at least futureTimeout for the operation to complete
    cf.awaitUninterruptibly(futureTimeout);
    // If the operation is not complete, cancel it.
    if(!cf.isDone()) {
      clog("Channel Future Still Waiting. Cancelled:" + cf.cancel());
    }
  }
View Full Code Here
87
88
89
90
91
92
93
94
95
96
97
//      cf.await();
      // wait interruptibly with a timeout of 2000 ms.
//      cf.await(2000, TimeUnit.MILLISECONDS);
      // wait uninterruptibly
      clog("Waiting for Channel Connect...");
      cf.awaitUninterruptibly();
      // wait uninterruptibly with a timeout of 2000 ms.
//      cf.awaitUninterruptibly(2000, TimeUnit.MILLISECONDS);
      // add a ChannelFutureListener that writes the Date when the connect is complete
//      cf.addListener(new ChannelFutureListener(){
//        public void operationComplete(ChannelFuture future) throws Exception {
View Full Code Here
81
82
83
84
85
86
87
88
89
90
91
      bootstrap.setPipelineFactory(pipelineFactory);
      InetSocketAddress addressToConnectTo = new InetSocketAddress("localhost", 8080);
      clog("Issuing Channel Connect...");
      ChannelFuture cf = bootstrap.connect(addressToConnectTo);
      clog("Waiting for Channel Connect...");
      cf.awaitUninterruptibly();
      Date dt = new Date();
      clog("Connected. Sending Date [" + dt + "]");
      Channel channel = cf.getChannel();
      channel.write(dt);
    } catch (Exception e) {
View Full Code Here
85
86
87
88
89
90
91
92
93
94
95
              System.out.println("CONNECT_UDP write to server unsuccessful: " + future.getCause().getMessage());
            }
          }
        });
       
        future.awaitUninterruptibly();
        WriteByte write = new WriteByte(c, serverAddress,iam);
        ZombieClient.SERVICE.scheduleAtFixedRate(write,10000l,5000l, TimeUnit.MILLISECONDS);
      }
      else
      {
View Full Code Here
43
44
45
46
47
48
49
50
51
52
53
      // Start the connection attempt.
      ChannelFuture future = bootstrap.connect(serverAddress);

      // Wait until the connection attempt succeeds or fails.
      channel = future.awaitUninterruptibly().getChannel();
      if (!future.isSuccess()) {
         bootstrap.releaseExternalResources();
         throw new TransportException("Could not create netty transport", future.getCause());
      }
   }
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.