Author: clebert.suconic(a)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)) {