[hornetq-commits] JBoss hornetq SVN: r11887 - branches/Branch_2_2_EAP/src/main/org/hornetq/core/server/cluster/impl.

Author: clebert.suconic(a)jboss.com Date: 2011-12-08 20:19:10 -0500 (Thu, 08 Dec 2011) New Revision: 11887 Modified: branches/Branch_2_2_EAP/src/main/org/hornetq/core/server/cluster/impl/ClusterConnectionImpl.java Log: I bumped into some error message while testing / validating JBPAPP-6522 - so I'm commiting it as part of this JIRA. This is a minor fix Modified: branches/Branch_2_2_EAP/src/main/org/hornetq/core/server/cluster/impl/ClusterConnectionImpl.java =================================================================== --- branches/Branch_2_2_EAP/src/main/org/hornetq/core/server/cluster/impl/ClusterConnectionImpl.java 2011-12-08 22:29:24 UTC (rev 11886) +++ branches/Branch_2_2_EAP/src/main/org/hornetq/core/server/cluster/impl/ClusterConnectionImpl.java 2011-12-09 01:19:10 UTC (rev 11887) @@ -27,6 +27,7 @@ import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.Executor; import java.util.concurrent.ScheduledExecutorService; +import java.util.concurrent.TimeUnit; import org.hornetq.api.core.DiscoveryGroupConfiguration; import org.hornetq.api.core.Pair; @@ -497,6 +498,14 @@ catch (Exception e) { log.warn("Unable to announce backup, retrying", e); + + scheduledExecutor.schedule(new Runnable(){ + public void run() + { + announceBackup(); + } + + }, retryInterval, TimeUnit.MILLISECONDS); } } });