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

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

Author: estebanschifman
Date: 2006-07-21 09:30:47 -0400 (Fri, 21 Jul 2006)
New Revision: 5218

Modified:
   labs/jbossesb/trunk/ESBCore/listeners/src/org/jboss/soa/esb/listeners/JmsQueueListener.java
Log:
Wrong parameter node in obtainQueue() - Fixed

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:34:05 UTC (rev 5217)
+++ labs/jbossesb/trunk/ESBCore/listeners/src/org/jboss/soa/esb/listeners/JmsQueueListener.java	2006-07-21 13:30:47 UTC (rev 5218)
@@ -339,7 +339,7 @@
 		obtainAtt(p_oP,LISTEN_QUEUE,null);		
 	} //________________________________
 
-	  protected final void obtainQueue() throws JMSException, NamingException
+	  protected final void obtainQueue(DomElement p_oP) throws JMSException, NamingException
 	  {
 	    try
 	    {
@@ -347,8 +347,8 @@
 	      m_oQsess		= null;
 	      m_oQueue		= null;
 	      
-	      String sQueue	= m_oParms.getAttr(LISTEN_QUEUE);
-	      String sFactClass	= m_oParms.getAttr(LISTEN_QUEUE_CONN_FACT);
+	      String sQueue	= p_oP.getAttr(LISTEN_QUEUE);
+	      String sFactClass	= p_oP.getAttr(LISTEN_QUEUE_CONN_FACT);
 	      if (EsbUtil.isNullString(sFactClass))
 	    	  sFactClass = "ConnectionFactory";
 
@@ -380,7 +380,7 @@
           	Thread.sleep(5000);
           	continue;
 		  }
-		  obtainQueue();
+		  obtainQueue(p_oP);
 	      String sSelector	= m_oParms.getAttr(LISTEN_MSG_SELECTOR);
 		  MessageConsumer oReader = m_oQsess.createReceiver(m_oQueue, sSelector);
 	      Message oMsg = (null==oReader) ? null