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

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

Author: kurt.stam at jboss.com
Date: 2006-11-07 14:17:11 -0500 (Tue, 07 Nov 2006)
New Revision: 7440

Modified:
   labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/actions/CbrProxyAction.java
   labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message/CbrJmsQueueListener.java
   labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message/JmsQueueReplyListener.java
Log:
CBR reply listener

Modified: labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/actions/CbrProxyAction.java
===================================================================
--- labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/actions/CbrProxyAction.java	2006-11-07 18:56:59 UTC (rev 7439)
+++ labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/actions/CbrProxyAction.java	2006-11-07 19:17:11 UTC (rev 7440)
@@ -94,7 +94,7 @@
         return routeAndDeliver(message);
     }
     /**
-     * Just route. 
+     * Just route. The routing returns the message with a Collection of destinationService names.
      * 
      * @param message
      * @return

Modified: labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message/CbrJmsQueueListener.java
===================================================================
--- labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message/CbrJmsQueueListener.java	2006-11-07 18:56:59 UTC (rev 7439)
+++ labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message/CbrJmsQueueListener.java	2006-11-07 19:17:11 UTC (rev 7440)
@@ -89,7 +89,7 @@
         			_logger.log(Priority.DEBUG, "Sending message to the Content Based Router.");
         			Collection<String> destinationServices = cbr.route(ruleSet, message);
         			if (Boolean.FALSE.equals(message.getProperties().getProperty(MessageRouter.DELIVER_MESSAGES))) {
-        				message.getBody().add(MessageRouter.ROUTING_DESTINATION_SERVICE_LIST, destinationServices);
+        				message.getProperties().setProperty(MessageRouter.ROUTING_DESTINATION_SERVICE_LIST, destinationServices);
         				try  { 
         					_logger.debug("Replying to caller");
         					//TODO For now it's ok to assume it's JMS. But going forward this needs to be fixed

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:56:59 UTC (rev 7439)
+++ labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message/JmsQueueReplyListener.java	2006-11-07 19:17:11 UTC (rev 7440)
@@ -58,7 +58,7 @@
 	
 	private static Logger _logger = Logger.getLogger(JmsQueueReplyListener.class);
 	private static long SLEEP_FOR_RETRY = 500;
-	private static long LISTEN_TIME_OUT = 5000;
+	private static long LISTEN_TIME_OUT = 50000;
 	private QueueConnection _Qconn = null;
 	private QueueSession 	_Qsess = null;
 	private Queue			_Queue = null;