@Test(expected = ConnectException.class, timeout = 10000) public void testLateRegistrationConnect() throws Exception { EventLoopGroup group = new DelayedEventLoopGroup(); try { final Bootstrap bootstrapA = new Bootstrap(); bootstrapA.group(group); bootstrapA.channel(LocalChannel.class); bootstrapA.handler(dummyHandler); bootstrapA.connect(LocalAddress.ANY).syncUninterruptibly(); } finally { group.shutdownGracefully(); } }
public ChannelFuture connect() { validate(); SocketAddress remoteAddress = this.remoteAddress; if (remoteAddress == null) { throw new IllegalStateException("remoteAddress not set"); } return doResolveAndConnect(remoteAddress, config.localAddress()); }
Bootstrap extends AbstractBootstrap<Bootstrap, Channel> { public ChannelFuture connect() { validate(); SocketAddress remoteAddress = this.remoteAddress; if (remoteAddress == null) { throw new IllegalStateException("remoteAddress not set"); } return doResolveAndConnect(remoteAddress, config.localAddress()); } }
Bootstrap extends AbstractBootstrap<Bootstrap, Channel> { public ChannelFuture connect() { validate(); SocketAddress remoteAddress = this.remoteAddress; if (remoteAddress == null) { throw new IllegalStateException("remoteAddress not set"); } return doResolveAndConnect(remoteAddress, config.localAddress()); } Bootstrap(); private  Bootstrap(Bootstrap bootstrap); }
Bootstrap extends AbstractBootstrap<Bootstrap, Channel> { public ChannelFuture connect() { validate(); SocketAddress remoteAddress = this.remoteAddress; if (remoteAddress == null) { throw new IllegalStateException("remoteAddress not set"); } return doResolveAndConnect(remoteAddress, config.localAddress()); } Bootstrap(); private  Bootstrap(Bootstrap bootstrap); @SuppressWarnings("unchecked") Bootstrap resolver(AddressResolverGroup<?> resolver); Bootstrap remoteAddress(SocketAddress remoteAddress); Bootstrap remoteAddress(String inetHost, int inetPort); Bootstrap remoteAddress(InetAddress inetHost, int inetPort); ChannelFuture connect(); ChannelFuture connect(String inetHost, int inetPort); ChannelFuture connect(InetAddress inetHost, int inetPort); ChannelFuture connect(SocketAddress remoteAddress); ChannelFuture connect(SocketAddress remoteAddress, SocketAddress localAddress); @Override Bootstrap validate(); @Override @SuppressWarnings("CloneDoesntCallSuperClone") Bootstrap clone(); Bootstrap clone(EventLoopGroup group); @Override final BootstrapConfig config(); }
Bootstrap extends AbstractBootstrap<Bootstrap, Channel> { public ChannelFuture connect() { validate(); SocketAddress remoteAddress = this.remoteAddress; if (remoteAddress == null) { throw new IllegalStateException("remoteAddress not set"); } return doResolveAndConnect(remoteAddress, config.localAddress()); } Bootstrap(); private  Bootstrap(Bootstrap bootstrap); @SuppressWarnings("unchecked") Bootstrap resolver(AddressResolverGroup<?> resolver); Bootstrap remoteAddress(SocketAddress remoteAddress); Bootstrap remoteAddress(String inetHost, int inetPort); Bootstrap remoteAddress(InetAddress inetHost, int inetPort); ChannelFuture connect(); ChannelFuture connect(String inetHost, int inetPort); ChannelFuture connect(InetAddress inetHost, int inetPort); ChannelFuture connect(SocketAddress remoteAddress); ChannelFuture connect(SocketAddress remoteAddress, SocketAddress localAddress); @Override Bootstrap validate(); @Override @SuppressWarnings("CloneDoesntCallSuperClone") Bootstrap clone(); Bootstrap clone(EventLoopGroup group); @Override final BootstrapConfig config();  }