[jboss-svn-commits] JBL Code SVN: r38435 - labs/jbossesb/trunk/product/rosetta/src/org/jboss/internal/soa/esb/addressing/eprs.

jboss-svn-commits at lists.jboss.org jboss-svn-commits at lists.jboss.org
Mon Nov 4 14:51:46 EST 2013


Author: tcunning
Date: 2013-11-04 14:51:46 -0500 (Mon, 04 Nov 2013)
New Revision: 38435

Modified:
   labs/jbossesb/trunk/product/rosetta/src/org/jboss/internal/soa/esb/addressing/eprs/DefaultJmsReplyToEpr.java
Log:
JBESB-3958
Commit Rick's fix to make DefaultJmsReplyToEpr more standard.



Modified: labs/jbossesb/trunk/product/rosetta/src/org/jboss/internal/soa/esb/addressing/eprs/DefaultJmsReplyToEpr.java
===================================================================
--- labs/jbossesb/trunk/product/rosetta/src/org/jboss/internal/soa/esb/addressing/eprs/DefaultJmsReplyToEpr.java	2013-11-04 19:36:06 UTC (rev 38434)
+++ labs/jbossesb/trunk/product/rosetta/src/org/jboss/internal/soa/esb/addressing/eprs/DefaultJmsReplyToEpr.java	2013-11-04 19:51:46 UTC (rev 38435)
@@ -29,23 +29,32 @@
 public class DefaultJmsReplyToEpr extends JMSEpr{
 
 	public static final String REPLY_UUID_TAG = "jbossESBresponseUUID";
+        private static final String ackMode = AcknowledgeMode.AUTO_ACKNOWLEDGE.toString();
 
 	public DefaultJmsReplyToEpr(JMSEpr epr)
 		throws URISyntaxException
 	{
-		super(	epr.getVersion()
-				,epr.getDestinationType()
-				,replyDestinationName(epr)
-				,epr.getConnectionFactory()
-				,epr.getJndiEnvironment()
-				,replySelector(epr)
-				,epr.getPersistent()
-			 );
+		super(epr.getVersion(), 
+				epr.getDestinationType(), 
+				replyDestinationName(epr), 
+				epr.getConnectionFactory(), 
+				epr.getJndiEnvironment(), 
+				replySelector(epr), 
+				epr.getPersistent(), 
+				ackMode, 
+				epr.getJMSSecurityPrincipal(), 
+				epr.getJMSSecurityCredential()
+			);
 	}
+
 	private static String replyDestinationName(JMSEpr toEpr)
 		throws URISyntaxException
 	{
-		return toEpr.getDestinationName()+JMSEpr.DEFAULT_REPLY_TO_DESTINATION_SUFFIX;
+		if  ("UPPERCASE" == System.getProperty("REPLY_TO_SUFFIX_CASE")){
+			return new StringBuilder().append(toEpr.getDestinationName()).append("_REPLY").toString();
+		} else {
+			return new StringBuilder().append(toEpr.getDestinationName()).append("_reply").toString();	
+		}
 	}
 	
 	/**



More information about the jboss-svn-commits mailing list