diff --git a/activemq-groups/src/main/java/org/apache/activegroups/Group.java b/activemq-groups/src/main/java/org/apache/activegroups/Group.java index be0f41228d..8d78af16f5 100644 --- a/activemq-groups/src/main/java/org/apache/activegroups/Group.java +++ b/activemq-groups/src/main/java/org/apache/activegroups/Group.java @@ -1340,8 +1340,8 @@ public class Group implements Map, Service { void checkMembership() { if (this.started.get() && this.electionFinished.get()) { - long checkTime = System.currentTimeMillis() - getHeartBeatInterval(); - boolean doElection = false; + long checkTime = System.currentTimeMillis() - (2 * getHeartBeatInterval()); // give it a bit more time since scheduler can be late + boolean doElection = false; for (Member member : this.members.values()) { if (member.getTimeStamp() < checkTime) { LOG.info("Member timestamp expired " + member);