[jboss-svn-commits] JBL Code SVN: r5217 - labs/jbossesb/trunk/ESBCore/listeners/src/org/jboss/soa/esb/listeners

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

Author: daniel.brum at jboss.com
Date: 2006-07-21 08:34:05 -0400 (Fri, 21 Jul 2006)
New Revision: 5217

Modified:
   labs/jbossesb/trunk/ESBCore/listeners/src/org/jboss/soa/esb/listeners/JmsQueueListener.java
Log:
bug fixes

Modified: labs/jbossesb/trunk/ESBCore/listeners/src/org/jboss/soa/esb/listeners/JmsQueueListener.java
===================================================================
--- labs/jbossesb/trunk/ESBCore/listeners/src/org/jboss/soa/esb/listeners/JmsQueueListener.java	2006-07-21 12:06:22 UTC (rev 5216)
+++ labs/jbossesb/trunk/ESBCore/listeners/src/org/jboss/soa/esb/listeners/JmsQueueListener.java	2006-07-21 12:34:05 UTC (rev 5217)
@@ -67,6 +67,7 @@
     String sFactoryClass = EsbSysProps.getParamsReposFactoryClass();
     m_oParmRepos = ParamsReposUtil.reposFromFactory(sFactoryClass,null);
     m_oParmsName = m_oParmRepos.nameFromString(p_sParamsUid);
+    runUntilEndRequested();
   } //__________________________________
   
   protected void runUntilEndRequested() throws Exception
@@ -379,6 +380,7 @@
           	Thread.sleep(5000);
           	continue;
 		  }
+		  obtainQueue();
 	      String sSelector	= m_oParms.getAttr(LISTEN_MSG_SELECTOR);
 		  MessageConsumer oReader = m_oQsess.createReceiver(m_oQueue, sSelector);
 	      Message oMsg = (null==oReader) ? null