@Override
    public void connect() {
        try {
            callbackRegistry.acceptConnectionStateChange(BitfinexConnectionStateEnum.CONNECTION_INIT);
            for (BitfinexWebsocketClient bitfinexWebsocketClient : clients.values()) {