import org.vertx.java.core.Handler;
import org.vertx.java.core.net.NetSocket;
import org.vertx.java.core.net.NetClient;
import org.vertx.java.platform.Verticle;
import org.vertx.java.core.streams.Pump;
public class ProxyServer extends Verticle {
public void start() {
vertx.createNetServer().connectHandler(new Handler<NetSocket>() {
public void handle(final NetSocket socket) {
NetClient client = vertx.createNetClient();
client.connect(9999, "192.168.0.254", new Handler<AsyncResult<NetSocket>>() {
public void handle(final AsyncResult<NetSocket> asyncSocket) {
NetSocket cSocket = asyncSocket.result();
Pump.createPump(cSocket, socket).start();
Pump.createPump(socket, cSocket).start();
}
});
}
}).listen(9999);
}
}