qbit/core/src/main/java/io/advantageous/qbit/server/WebSocketServiceServerHandler.java
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