[jboss-svn-commits] JBL Code SVN: r7438 - 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-07 13:55:47 -0500 (Tue, 07 Nov 2006)
New Revision: 7438

Modified:
   labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message/JmsQueueReplyListener.java
Log:
Message selector is now in the JMSEpr

Modified: labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message/JmsQueueReplyListener.java
===================================================================
--- labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message/JmsQueueReplyListener.java	2006-11-07 18:49:49 UTC (rev 7437)
+++ labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message/JmsQueueReplyListener.java	2006-11-07 18:55:47 UTC (rev 7438)
@@ -83,7 +83,7 @@
      * @param selector
      * @return
      */
-    private MessageConsumer getConsumer(JMSEpr epr, String selector) 
+    private MessageConsumer getConsumer(JMSEpr epr) 
     {
         _Qconn = null;
         _Qsess = null;
@@ -100,7 +100,7 @@
         	_Queue = (Queue) context.lookup(epr.getDestinationName());
         	_Qsess = _Qconn.createQueueSession(false,QueueSession.AUTO_ACKNOWLEDGE);
         	_Qconn.start();
-        	return _Qsess.createReceiver(_Queue, selector);
+        	return _Qsess.createReceiver(_Queue, epr.getMessageSelector());
         }
         catch (URISyntaxException e)			{ thrown = e; }
         catch (javax.naming.NamingException e)	{ thrown = e; }
@@ -109,7 +109,7 @@
         return null;
     }
 
-    public Message listen(JMSEpr epr, String uniqueReplySelector)
+    public Message listen(JMSEpr epr)
     {
     	MessageConsumer consumer = null;
     	javax.jms.Message jmsMessage = null;
@@ -117,7 +117,7 @@
         	for (int i = 0; i < 3; i++)
         		try 
         		{ 
-        			consumer = getConsumer(epr, uniqueReplySelector); 
+        			consumer = getConsumer(epr); 
                 	jmsMessage = consumer.receive(LISTEN_TIME_OUT);
                 	break;
         		}