diff --git a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-cluster-protocol/src/main/java/org/apache/nifi/cluster/coordination/heartbeat/HeartbeatMonitor.java b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-cluster-protocol/src/main/java/org/apache/nifi/cluster/coordination/heartbeat/HeartbeatMonitor.java index 3cc5fd0ca4..6a0937d99c 100644 --- a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-cluster-protocol/src/main/java/org/apache/nifi/cluster/coordination/heartbeat/HeartbeatMonitor.java +++ b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-cluster-protocol/src/main/java/org/apache/nifi/cluster/coordination/heartbeat/HeartbeatMonitor.java @@ -58,13 +58,6 @@ public interface HeartbeatMonitor { */ void purgeHeartbeats(); - /** - * Returns when the heartbeats were purged last. - * - * @return when the heartbeats were purged last - */ - long getPurgeTimestamp(); - /** * @return the address that heartbeats should be sent to when this node is elected coordinator. */ diff --git a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-cluster/src/main/java/org/apache/nifi/cluster/coordination/heartbeat/AbstractHeartbeatMonitor.java b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-cluster/src/main/java/org/apache/nifi/cluster/coordination/heartbeat/AbstractHeartbeatMonitor.java index c5d9e4bc6c..4c251f9fdf 100644 --- a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-cluster/src/main/java/org/apache/nifi/cluster/coordination/heartbeat/AbstractHeartbeatMonitor.java +++ b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-cluster/src/main/java/org/apache/nifi/cluster/coordination/heartbeat/AbstractHeartbeatMonitor.java @@ -281,6 +281,13 @@ public abstract class AbstractHeartbeatMonitor implements HeartbeatMonitor { */ protected abstract Map getLatestHeartbeats(); + /** + * Returns when the heartbeats were purged last. + * + * @return when the heartbeats were purged last + */ + protected abstract long getPurgeTimestamp(); + /** * This method does nothing in the abstract class but is meant for * subclasses to override in order to provide functionality when the monitor