[jboss-svn-commits] JBL Code SVN: r7391 - 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-03 17:44:18 -0500 (Fri, 03 Nov 2006)
New Revision: 7391

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
Log:
work in progress.

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-03 22:27:53 UTC (rev 7390)
+++ labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/actions/CbrProxyAction.java	2006-11-03 22:44:18 UTC (rev 7391)
@@ -114,6 +114,7 @@
     	if (! (epr instanceof JMSEpr))
     		return null;
 
+    	//Create a string that has the format of a message selector
     	StringBuilder sb = new StringBuilder()
     		.append(CbrJmsQueueListener.CORRELATION_ID_TAG).append("='")
     		.append(replyId).append("'")
@@ -206,7 +207,7 @@
         			catch (InterruptedException e1)
         			{ // Just return after logging
         				_logger.error("Unexpected thread interupt exception.", e);
-        				return null;
+        				break;
                     }
                  }
         }

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-03 22:27:53 UTC (rev 7390)
+++ labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/message/CbrJmsQueueListener.java	2006-11-03 22:44:18 UTC (rev 7391)
@@ -94,7 +94,7 @@
 	        					if (replyTo!=null) {
 	        						CourierFactory.getCourier(replyTo).deliver(message);
 	        					} else {
-	        						_logger.log(Priority.ERROR, "Unable to reply to caller. Could not optain replyTo EPR");
+	        						_logger.log(Priority.ERROR, "Unable to reply to caller. Could not optain replyTo EPR.");
 	        					}
 	        				} catch (URISyntaxException use) {
 	        					_logger.log(Priority.ERROR, "Unable to reply to caller. "+ use.getLocalizedMessage(), use);