public synchronized void reconnect(WebSocketClient client) {
    log.info("Attempting websocket reconnection...");
    try {
        if (!client.reconnectBlocking()) {
            log.error("Reconnect failed!");
        } else {
            log.info("Websocket reconnected successfully.");
        }
    } catch (InterruptedException e) {
        log.error("Reconnect failed!", e);
    }
}
 

public WebSocketResubscribeNodeFailureListener(SubscriptionService subscriptionService,
                                               BlockchainService blockchainService,
                                               WebSocketReconnectionManager reconnectionManager,
                                               WebSocketClient client) {
    super(subscriptionService, blockchainService);

    this.reconnectionManager = reconnectionManager;
    this.client = client;
    this.blockchainService = blockchainService;
}