this.lastHeartbeat = System.currentTimeMillis();
        this.heartbeatFailures = 0;
    }

    /**
     * Increments the heartbeat failure count.
     */
    public void incrementHeartbeatFailures() {
        this.heartbeatFailures++;
    }

    /**
     * Gets the number of consecutive heartbeat failures.
     *
     * @return the number of consecutive heartbeat failures
     */

                registration.incrementHeartbeatFailures();
            }

        } catch (Exception e) {
            log.debug("Heartbeat error for registration: {}", registration.getRegistrationId(), e);
            registration.incrementHeartbeatFailures();
        }
    }

    /**
     * Gets the witness server address.
     *