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

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2011-03-10 11:57:09 -0500 (Thu, 10 Mar 2011)
New Revision: 10311

Modified:
   branches/Branch_2_2_EAP/src/main/org/hornetq/core/server/cluster/impl/BridgeImpl.java
Log:
fixing test

Modified: branches/Branch_2_2_EAP/src/main/org/hornetq/core/server/cluster/impl/BridgeImpl.java
===================================================================
--- branches/Branch_2_2_EAP/src/main/org/hornetq/core/server/cluster/impl/BridgeImpl.java	2011-03-09 19:16:16 UTC (rev 10310)
+++ branches/Branch_2_2_EAP/src/main/org/hornetq/core/server/cluster/impl/BridgeImpl.java	2011-03-10 16:57:09 UTC (rev 10311)
@@ -515,7 +515,19 @@
 
             if (forwardingAddress != null)
             {
-               BindingQuery query = session.bindingQuery(forwardingAddress);
+               BindingQuery query = null;
+               
+               try
+               {
+                  query = session.bindingQuery(forwardingAddress);
+               }
+               catch (Throwable e)
+               {
+                  log.warn("Error on querying binding. Retrying", e);
+                  retry = true;
+                  Thread.sleep(100);
+                  continue;
+               }
    
                if (forwardingAddress.startsWith(BridgeImpl.JMS_QUEUE_ADDRESS_PREFIX) || forwardingAddress.startsWith(BridgeImpl.JMS_TOPIC_ADDRESS_PREFIX))
                {