diff --git a/transport/src/main/java/io/netty/channel/ChannelBootstrap.java b/transport/src/main/java/io/netty/channel/ChannelBootstrap.java index 0437b96ea0..03d29bdf89 100644 --- a/transport/src/main/java/io/netty/channel/ChannelBootstrap.java +++ b/transport/src/main/java/io/netty/channel/ChannelBootstrap.java @@ -3,6 +3,7 @@ package io.netty.channel; import io.netty.logging.InternalLogger; import io.netty.logging.InternalLoggerFactory; +import java.net.InetSocketAddress; import java.net.SocketAddress; import java.nio.channels.ClosedChannelException; import java.util.LinkedHashMap; @@ -61,11 +62,26 @@ public class ChannelBootstrap { return this; } + public ChannelBootstrap localAddress(int port) { + localAddress = new InetSocketAddress(port); + return this; + } + + public ChannelBootstrap localAddress(String host, int port) { + localAddress = new InetSocketAddress(host, port); + return this; + } + public ChannelBootstrap remoteAddress(SocketAddress remoteAddress) { this.remoteAddress = remoteAddress; return this; } + public ChannelBootstrap remoteAddress(String host, int port) { + remoteAddress = new InetSocketAddress(host, port); + return this; + } + public ChannelFuture bind() { validate(); return bind(channel.newFuture()); diff --git a/transport/src/main/java/io/netty/channel/ServerChannelBootstrap.java b/transport/src/main/java/io/netty/channel/ServerChannelBootstrap.java index 2dd0c680b7..cf6090ea84 100644 --- a/transport/src/main/java/io/netty/channel/ServerChannelBootstrap.java +++ b/transport/src/main/java/io/netty/channel/ServerChannelBootstrap.java @@ -17,7 +17,7 @@ public class ServerChannelBootstrap { private static final InternalLogger logger = InternalLoggerFactory.getInstance(ServerChannelBootstrap.class); private static final InetSocketAddress DEFAULT_LOCAL_ADDR = new InetSocketAddress(SocketAddresses.LOCALHOST, 0); - private final ChannelHandler acceptor = new ChannelInitializer() { + private final ChannelHandler acceptor = new ChannelInitializer() { @Override public void initChannel(Channel ch) throws Exception { Acceptor acceptor = new Acceptor(); @@ -96,6 +96,16 @@ public class ServerChannelBootstrap { return this; } + public ServerChannelBootstrap localAddress(int port) { + localAddress = new InetSocketAddress(port); + return this; + } + + public ServerChannelBootstrap localAddress(String host, int port) { + localAddress = new InetSocketAddress(host, port); + return this; + } + public ChannelFuture bind() { validate(); return bind(channel.newFuture());