Support reponse forbidden better
This commit is contained in:
parent
fc658c3805
commit
5bf71f5125
|
@ -262,6 +262,9 @@ public class WebSocketAsyncConnection extends AbstractAsyncConnection implements
|
|||
{
|
||||
LOG.debug("onOpen()");
|
||||
super.onOpen();
|
||||
// TODO: websocket.setConnection(this);
|
||||
// TODO: websocket.onConnect();
|
||||
|
||||
fillInterested();
|
||||
}
|
||||
|
||||
|
|
|
@ -119,7 +119,12 @@ public class WebSocketServerFactory extends AbstractLifeCycle implements WebSock
|
|||
WebSocketCreator creator = getCreator();
|
||||
|
||||
Object websocketPojo = creator.createWebSocket(sockreq,sockresp);
|
||||
// TODO: Handle forbidden?
|
||||
|
||||
// Handle response forbidden (and similar paths)
|
||||
if (sockresp.isCommitted())
|
||||
{
|
||||
return false;
|
||||
}
|
||||
|
||||
if (websocketPojo == null)
|
||||
{
|
||||
|
@ -128,8 +133,6 @@ public class WebSocketServerFactory extends AbstractLifeCycle implements WebSock
|
|||
return false;
|
||||
}
|
||||
|
||||
// TODO: discover type, create proxy
|
||||
|
||||
// Send the upgrade
|
||||
WebSocketPolicy objPolicy = this.basePolicy.clonePolicy();
|
||||
WebSocketEventDriver websocket = new WebSocketEventDriver(websocketPojo,methodsCache,objPolicy,bufferPool);
|
||||
|
|
Loading…
Reference in New Issue