@ Override public void handle ( final ServerWebSocket socket ) { LOGGER . info ( "New web socket connection {}, {}" , socket , socket . uri ( ) ) ; if ( ! configuration . accept ( socket . uri ( ) ) ) { LOGGER . warn ( "Web Socket connection denied on {} by {}" , socket . uri ( ) , configuration . name ( ) ) ; return ; } final Socket sock = new Socket ( socket ) ; accessor . getDispatcher ( ) . addSocket ( socket . path ( ) , sock ) ; socket . closeHandler ( event -> { LOGGER . info ( "Web Socket closed {}, {}" , socket , socket . uri ( ) ) ; accessor . getDispatcher ( ) . removeSocket ( socket . path ( ) , sock ) ; } ) ; socket . handler ( event -> accessor . getDispatcher ( ) . received ( socket . path ( ) , event . getBytes ( ) , sock ) ) ; }
Handles a web socket connection .