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);
            }

        });

    }
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);
            }

        });

    }
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.

@param webSocketMessage websocket message
All WebSocket calls come through here .