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

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

Author: tcunning
Date: 2013-10-28 15:05:26 -0400 (Mon, 28 Oct 2013)
New Revision: 38430

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


Modified: labs/jbossesb/branches/JBESB_4_11_CP2/product/rosetta/src/org/jboss/internal/soa/esb/addressing/eprs/DefaultJmsReplyToEpr.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_11_CP2/product/rosetta/src/org/jboss/internal/soa/esb/addressing/eprs/DefaultJmsReplyToEpr.java	2013-10-28 16:52:33 UTC (rev 38429)
+++ labs/jbossesb/branches/JBESB_4_11_CP2/product/rosetta/src/org/jboss/internal/soa/esb/addressing/eprs/DefaultJmsReplyToEpr.java	2013-10-28 19:05:26 UTC (rev 38430)
@@ -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();	
+		}
 	}
 	
 	/**