/**
 * Configure the Async HTTP Client
 */
protected AsyncHttpClientConfig getConfig () {
 AsyncHttpClientConfig.Builder configBuilder = new AsyncHttpClientConfig.Builder();
 if ( ntlmDomain != null ) {
 configBuilder
 .setRealm(new Realm.RealmBuilder()
 .setPrincipal(this.username)
 .setPassword(this.password)
 .setNtlmDomain(this.ntlmDomain)
 .setUsePreemptiveAuth(true)
 .build());
 }
 return configBuilder.build();
}
public void execute () {
 AsyncHttpClientConfig config = this.getConfig();
 this.client = new AsyncHttpClient(config);
 try {
 Future<WebSocket> futureWebsocket;
 ProxyServer proxy = new ProxyServer(this.proxyProtocol, this.proxyServer, this.proxyServerPort,
 this.username, this.password);
 if ( ntlmDomain != null ) {
 proxy.setNtlmDomain(ntlmDomain);
 }
 futureWebsocket =
 this.client.prepareGet(this.wsUrl)
 .setProxyServer(proxy)
 .execute(new WebSocketUpgradeHandler.Builder().build());
 LOG.info("waiting for websocket connection");
 final WebSocket websocket = futureWebsocket.get();
 if ( websocket != null ) {
 LOG.info("received websocket connection");
 websocket.addWebSocketListener(new WebSocketTextListener() {
 @Override
 public void onMessage(String s) {
 LOG.info("received response {}", s);
 processAgentRequest(websocket, s);
 }
 ...
}