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

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

Author: estebanschifman
Date: 2006-11-29 13:24:59 -0500 (Wed, 29 Nov 2006)
New Revision: 7940

Modified:
   labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message/EsbListenerController.java
Log:
Patch (ugly)for unregister problem in trailblazer and examples

Modified: labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message/EsbListenerController.java
===================================================================
--- labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message/EsbListenerController.java	2006-11-29 17:54:42 UTC (rev 7939)
+++ labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message/EsbListenerController.java	2006-11-29 18:24:59 UTC (rev 7940)
@@ -101,6 +101,7 @@
 
 	private String m_sParmsName;
 	private ConfigTree m_oParms;
+	private Object _registrySynch = new Object();
 
 	private HashMap<String, Object> m_oAtts;
 
@@ -568,7 +569,12 @@
 		String serviceDescription  = config.getAttribute(ListenerTagNames.SERVICE_DESCRIPTION_TAG);
 		String eprDescription      = config.getAttribute(ListenerTagNames.EPR_DESCRIPTION_TAG);
 		Registry registry = RegistryFactory.getRegistry();
-		registry.registerEPR(serviceCategoryName, serviceName, serviceDescription, epr, eprDescription);
+		try { Thread.sleep(1000); }
+		catch(InterruptedException e) { return;}
+		synchronized (_registrySynch)
+		{
+			registry.registerEPR(serviceCategoryName, serviceName, serviceDescription, epr, eprDescription);
+		}
 	}
 	/**
 	 * Unregister the EPR from the registry.
@@ -586,7 +592,10 @@
 				return;
 		}
 		Registry registry = RegistryFactory.getRegistry();
-		registry.unRegisterEPR(serviceCategoryName, serviceName, epr);
+		synchronized (_registrySynch)
+		{
+			registry.unRegisterEPR(serviceCategoryName, serviceName, epr);
+		}
 	}