writeSync.release();
}
protected AsyncSocketChannel createSocket(URI remoteLocation) throws UnknownHostException, IOException, InterruptedException {
AsyncSocketChannel answer = AsyncSocketChannel.open();
IConnectionFuture future = answer.connect(new InetSocketAddress(remoteLocation.getHost(), remoteLocation.getPort()));
future.waitForCompletion();
return answer;
}