Examples of org.jboss.netty.channel.SucceededChannelFuture

org.jboss.netty.channel.SucceededChannelFuture
The {@link CompleteChannelFuture} which is succeeded already. It isrecommended to use {@link Channels#succeededFuture(Channel)} instead ofcalling the constructor of this future.

            // really fire and forget. You wont get an PortUnreachableException
            // if no one is listen on the port
            if (!configuration.isUdpConnectionlessSending()) {
                answer = connectionlessClientBootstrap.connect(new InetSocketAddress(configuration.getHost(), configuration.getPort()));
            } else {
                answer = new SucceededChannelFuture(channel);
            }
            
            if (LOG.isDebugEnabled()) {
                LOG.debug("Created new UDP client bootstrap connecting to {}:{} with options: {}",
                       new Object[]{configuration.getHost(), configuration.getPort(), connectionlessClientBootstrap.getOptions()});

View Full Code Here


    @Override
    public ChannelFuture close() {
        closed = true;
        closingFuture.setSuccess();
        return new SucceededChannelFuture(this);
    }

View Full Code Here

    }


    @Override
    public ChannelFuture write(Object message) {
        messagesWritten.add(message);
        return new SucceededChannelFuture(this);
    }

View Full Code Here

TOP

Related Classes of org.jboss.netty.channel.SucceededChannelFuture

org.apache.camel.component.netty.NettyProducer

org.apache.hedwig.server.netty.WriteRecordingChannel

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.