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