@Override
    public void onMessage(final String result) {
        if (LOG.isDebugEnabled()) {
            LOG.debug("onMessage server[{}] result({})", this.getURI().toString(), result);
        }
        
        Map<String, Object> jsonToMap = JsonUtils.jsonToMap(result);
        Object eventType = jsonToMap.get(RunningModeConstants.EVENT_TYPE);
        if (Objects.equals(DataEventTypeEnum.RUNNING_MODE.name(), eventType)) {
            LOG.info("server[{}] handle running mode result({})", this.getURI().toString(), result);
            this.runningMode = String.valueOf(jsonToMap.get(RunningModeConstants.RUNNING_MODE));
            if (Objects.equals(RunningModeEnum.STANDALONE.name(), runningMode)) {
                return;
            }
            this.masterUrl = String.valueOf(jsonToMap.get(RunningModeConstants.MASTER_URL));
            this.isConnectedToMaster = Boolean.TRUE.equals(jsonToMap.get(RunningModeConstants.IS_MASTER));
        } else {
            handleResult(result);
        }
    }
@Test
    public void testOnMessage() {
        doNothing().when(pluginDataSubscriber).onSubscribe(any());
        String json = GsonUtils.getInstance().toJson(websocketData);
        shenyuWebsocketClient.onMessage(json);
        verify(pluginDataSubscriber).onSubscribe(any());
    }