[jboss-svn-commits] JBL Code SVN: r5240 - 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 19:44:29 -0400 (Fri, 21 Jul 2006)
New Revision: 5240

Modified:
   labs/jbossesb/trunk/ESBCore/listeners/src/org/jboss/soa/esb/listeners/JmsQueueListener.java
Log:
fixed reading of MessageSelector parameter, was reading from wrong level of the DOM

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 23:43:49 UTC (rev 5239)
+++ labs/jbossesb/trunk/ESBCore/listeners/src/org/jboss/soa/esb/listeners/JmsQueueListener.java	2006-07-21 23:44:29 UTC (rev 5240)
@@ -12,6 +12,7 @@
 import javax.naming.*;
 import javax.jms.*;
 
+import org.jboss.soa.esb.samples.loanbroker.domain.LoanBrokerConstants;
 import org.jboss.soa.esb.services.*;
 import org.jboss.soa.esb.util.*;
 import org.jboss.soa.esb.common.*;
@@ -28,6 +29,7 @@
   											 // parameter reloading
   ;
   
+  //attributes that need to be set in the xml parameter file for the service
   public static final String PARM_ACTION_CLASS		= "actionClass";
 
   public static final String PARM_RELOAD_LTCY 		= "parmsReloadSecs";
@@ -257,6 +259,8 @@
     protected QueueSession	m_oQsess;
     protected Queue			m_oQueue;
     
+    protected String		m_sSelectorService;
+    
     protected GroupOfChilds(ThreadGroup p_oThrGrp) throws Exception
     {
       m_oThrGrp = p_oThrGrp;
@@ -338,6 +342,11 @@
 		
 		obtainAtt(p_oP,LISTEN_QUEUE,null);
 		
+		m_sSelectorService = obtainAtt(p_oP,LISTEN_MSG_SELECTOR,null);
+		
+		
+		
+		
 		String sClass = obtainAtt(p_oP,PARM_ACTION_CLASS,null);
 		if (EsbUtil.isNullString(sClass))
 			throw new Exception(formatLogMsg("Missing value for "+PARM_ACTION_CLASS));
@@ -387,8 +396,8 @@
           	continue;
 		  }
 		  obtainQueue(p_oP);
-	      String sSelector	= m_oParms.getAttr(LISTEN_MSG_SELECTOR);
-		  MessageConsumer oReader = m_oQsess.createReceiver(m_oQueue, sSelector);
+	      //String sSelector	= m_oParms.getAttr(LISTEN_MSG_SELECTOR);
+		  MessageConsumer oReader = m_oQsess.createReceiver(m_oQueue, m_sSelectorService);
 	      Message oMsg = (null==oReader) ? null
 	    		  : oReader.receiveNoWait();
 	      if (null==oMsg)