svn commit: r488685 - /webservices/sandesha/trunk/java/src/org/apache/sandesha2/msgprocessors/ApplicationMsgProcessor.java

[gatfora]

Author: gatfora
Date: Tue Dec 19 06:11:08 2006
New Revision: 488685

URL: http://svn.apache.org/viewvc?view=rev&rev=488685
Log:
Don't override the replyToEPR for application messages

Modified:
    
webservices/sandesha/trunk/java/src/org/apache/sandesha2/msgprocessors/ApplicationMsgProcessor.java

Modified: 
webservices/sandesha/trunk/java/src/org/apache/sandesha2/msgprocessors/ApplicationMsgProcessor.java
URL: 
http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/src/org/apache/sandesha2/msgprocessors/ApplicationMsgProcessor.java?view=diff&rev=488685&r1=488684&r2=488685
==============================================================================
--- 
webservices/sandesha/trunk/java/src/org/apache/sandesha2/msgprocessors/ApplicationMsgProcessor.java
 (original)
+++ 
webservices/sandesha/trunk/java/src/org/apache/sandesha2/msgprocessors/ApplicationMsgProcessor.java
 Tue Dec 19 06:11:08 2006
@@ -591,8 +591,6 @@
 
                SequencePropertyBean toBean = 
sequencePropertyMgr.retrieve(internalSequenceId,
                                Sandesha2Constants.SequenceProperties.TO_EPR);
-               SequencePropertyBean replyToBean = 
sequencePropertyMgr.retrieve(internalSequenceId,
-                               
Sandesha2Constants.SequenceProperties.REPLY_TO_EPR);
 
                if (toBean == null) {
                        String message = 
SandeshaMessageHelper.getMessage(SandeshaMessageKeys.toEPRNotValid, null);
@@ -602,11 +600,6 @@
 
                EndpointReference toEPR = new 
EndpointReference(toBean.getValue());
 
-               EndpointReference replyToEPR = null;
-               if (replyToBean != null) {
-                       replyToEPR = new 
EndpointReference(replyToBean.getValue());
-               }
-
                if (toEPR == null || toEPR.getAddress() == null || 
"".equals(toEPR.getAddress())) {
                        String message = 
SandeshaMessageHelper.getMessage(SandeshaMessageKeys.toEPRNotValid, null);
                        log.debug(message);
@@ -627,9 +620,6 @@
                        rmMsg.setTo(new EndpointReference(newToStr));
                else
                        rmMsg.setTo(toEPR);
-
-               if (replyToEPR != null)
-                       rmMsg.setReplyTo(replyToEPR);
 
                String rmVersion = 
SandeshaUtil.getRMVersion(internalSequenceId, storageManager);
                if (rmVersion == null)



---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]