svn commit: r803465 - /activemq/trunk/activemq-groups/src/main/java/org/apache/activegroups/Group.java

[dejanb]

Author: dejanb
Date: Wed Aug 12 12:03:17 2009
New Revision: 803465

URL: http://svn.apache.org/viewvc?rev=803465&view=rev
Log:
fix for intermittent failure of 
org.apache.activegroups.GroupStateTest.testExpire test

Modified:
    
activemq/trunk/activemq-groups/src/main/java/org/apache/activegroups/Group.java

Modified: 
activemq/trunk/activemq-groups/src/main/java/org/apache/activegroups/Group.java
URL: 
http://svn.apache.org/viewvc/activemq/trunk/activemq-groups/src/main/java/org/apache/activegroups/Group.java?rev=803465&r1=803464&r2=803465&view=diff
==============================================================================
--- 
activemq/trunk/activemq-groups/src/main/java/org/apache/activegroups/Group.java 
(original)
+++ 
activemq/trunk/activemq-groups/src/main/java/org/apache/activegroups/Group.java 
Wed Aug 12 12:03:17 2009
@@ -1340,8 +1340,8 @@
 
     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);