[jboss-svn-commits] JBL Code SVN: r8800 - labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway.

[jboss-svn-commits at lists.jboss.org]

Author: estebanschifman
Date: 2007-01-10 11:34:55 -0500 (Wed, 10 Jan 2007)
New Revision: 8800

Modified:
   labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway/GatewayListenerController.java
Log:
Add code to retry a few times if service is not available

Modified: labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway/GatewayListenerController.java
===================================================================
--- labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway/GatewayListenerController.java	2007-01-10 16:01:54 UTC (rev 8799)
+++ labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway/GatewayListenerController.java	2007-01-10 16:34:55 UTC (rev 8800)
@@ -598,7 +598,21 @@
 			}
 			catch(IOException e) {throw new RegistryException("No EPRs found for <"+category+"><"+name+">");}
 		}
-		return RegistryFactory.getRegistry().findEPRs(category, name);
+		
+		Registry reg = RegistryFactory.getRegistry();
+		RegistryException eReg = null;
+		for (int i1=0; i1<5; i1++)
+		{
+			try { return reg.findEPRs(category, name); }
+			catch(RegistryException e)
+			{
+				if (null==eReg)
+					eReg = e;
+				try 	{ Thread.sleep(500); }
+				catch 	(InterruptedException eInt) { break;  }
+			}
+		}
+		throw eReg;
 	}
 	
 	/**