public void handleWebSocketCall ( final WebSocketMessage webSocketMessage ) { if ( debug ) logger . debug ( "WebSocket message: " + webSocketMessage ) ; WebSocketDelegate webSocketDelegate = webSocketDelegateMap . get ( webSocketMessage . getRemoteAddress ( ) ) ; if ( webSocketDelegate == null ) { webSocketDelegate = new WebSocketDelegate ( protocolBatchSize , webSocketMessage ) ; webSocketDelegateMap . put ( webSocketMessage . getRemoteAddress ( ) , webSocketDelegate ) ; } protocolParserThreadPool . execute ( ( ) -> { try { final List < MethodCall < Object > > methodCallListToBeParsedFromBody = createMethodCallListToBeParsedFromBody ( webSocketMessage . getRemoteAddress ( ) , webSocketMessage . getMessage ( ) , webSocketMessage ) ; if ( methodCallListToBeParsedFromBody . size ( ) > 0 ) { methodCallSendQueue . sendBatch ( methodCallListToBeParsedFromBody ) ; } } catch ( Exception ex ) { logger . error ( "" , ex ) ; } } ) ; }
All WebSocket calls come through here .