Making Simone jubilantly happy :-)
This commit is contained in:
parent
b2951bdf5d
commit
728201fa3e
|
@ -81,16 +81,16 @@ public abstract class ConnectPromise extends FuturePromise<Session> implements R
|
|||
return response;
|
||||
}
|
||||
|
||||
public void onOpen(WebSocketSession session)
|
||||
public void setResponse(ClientUpgradeResponse response)
|
||||
{
|
||||
this.response = response;
|
||||
}
|
||||
|
||||
public void succeeded(WebSocketSession session)
|
||||
{
|
||||
session.setUpgradeRequest(request);
|
||||
session.setUpgradeResponse(response);
|
||||
session.open();
|
||||
super.succeeded(session);
|
||||
}
|
||||
|
||||
public void setResponse(ClientUpgradeResponse response)
|
||||
{
|
||||
this.response = response;
|
||||
}
|
||||
}
|
|
@ -80,7 +80,7 @@ public class WebSocketClientConnection extends AbstractWebSocketConnection
|
|||
WebSocketSession session = getSession();
|
||||
ConnectionManager connectionManager = connectPromise.getClient().getConnectionManager();
|
||||
connectionManager.addSession(session);
|
||||
connectPromise.onOpen(session);
|
||||
connectPromise.succeeded(session);
|
||||
connected = true;
|
||||
}
|
||||
super.onOpen();
|
||||
|
|
Loading…
Reference in New Issue