svn commit: r449267 [3/3] - in /webservices/sandesha/trunk/java/src/org/apache/sandesha2: client/ msgprocessors/ util/

[chamikara]

Modified: 
webservices/sandesha/trunk/java/src/org/apache/sandesha2/util/RMMsgCreator.java
URL: 
http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/src/org/apache/sandesha2/util/RMMsgCreator.java?view=diff&rev=449267&r1=449266&r2=449267
==============================================================================
--- 
webservices/sandesha/trunk/java/src/org/apache/sandesha2/util/RMMsgCreator.java 
(original)
+++ 
webservices/sandesha/trunk/java/src/org/apache/sandesha2/util/RMMsgCreator.java 
Sat Sep 23 08:59:05 2006
@@ -206,7 +206,7 @@
         * @throws SandeshaException

         */

        public static RMMsgContext createCreateSeqMsg(RMMsgContext 
applicationRMMsg, String sequencePropertyKey,

-                       String acksTo, StorageManager storageManager) throws 
AxisFault {

+                       EndpointReference acksTo, StorageManager 
storageManager) throws AxisFault {

 

                MessageContext applicationMsgContext = 
applicationRMMsg.getMessageContext();

                if (applicationMsgContext == null)

@@ -319,14 +319,11 @@
 

                EndpointReference toEPR = new 
EndpointReference(toBean.getValue());

                EndpointReference replyToEPR = null;

-               EndpointReference acksToEPR = null;

 

                String anonymousURI = 
SpecSpecificConstants.getAddressingAnonymousURI(addressingNamespaceValue);

 

-               if (acksTo == null || "".equals(acksTo))

-                       acksTo = anonymousURI;

-

-               acksToEPR = new EndpointReference(acksTo);

+               if (acksTo==null || acksTo.getAddress() == null || 
"".equals(acksTo.getAddress()))

+                       acksTo = new EndpointReference(anonymousURI);

 

                if (replyToBean != null && replyToBean.getValue() != null)

                        replyToEPR = new 
EndpointReference(replyToBean.getValue());

@@ -338,7 +335,7 @@
                if (replyToEPR != null)

                        createSeqRMMsg.setReplyTo(replyToEPR);

 

-               createSequencePart.setAcksTo(new AcksTo(new Address(acksToEPR, 
addressingNamespaceValue), factory,

+               createSequencePart.setAcksTo(new AcksTo(new Address(acksTo, 
addressingNamespaceValue), factory,

                                rmNamespaceValue, addressingNamespaceValue));

                

                // Find the token that should be used to secure this new 
sequence. If there is a token, then we




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