@Override
    public void onOpen(final ServerHandshake serverHandshake) {
        LOG.info("websocket connection server[{}] is opened, sending sync msg", this.getURI().toString());
        send(DataEventTypeEnum.RUNNING_MODE.name());
        if (!alreadySync) {
            send(DataEventTypeEnum.MYSELF.name());
            alreadySync = true;
        }
    }
@Test
    public void testOnOpen() {
        shenyuWebsocketClient = spy(shenyuWebsocketClient);
        ServerHandshake serverHandshake = mock(ServerHandshake.class);
        doNothing().when(shenyuWebsocketClient).send(DataEventTypeEnum.RUNNING_MODE.name());
        doNothing().when(shenyuWebsocketClient).send(DataEventTypeEnum.MYSELF.name());
        shenyuWebsocketClient.onOpen(serverHandshake);
        verify(shenyuWebsocketClient).send(DataEventTypeEnum.RUNNING_MODE.name());
        verify(shenyuWebsocketClient).send(DataEventTypeEnum.MYSELF.name());
    }