code: 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);
              }
  
          });
  
      }
docs: All WebSocket calls come through here.
  
  @param webSocketMessage websocket message