Author: sumedha
Date: Mon Sep 24 06:38:47 2007
New Revision: 578811
URL: http://svn.apache.org/viewvc?rev=578811&view=rev
Log:
reverting change to AckRequestedProcessor by r578652.Incorrect logic.
Modified:
webservices/sandesha/branches/sandesha2/java/1_3/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/AckRequestedProcessor.java
Modified:
webservices/sandesha/branches/sandesha2/java/1_3/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/AckRequestedProcessor.java
URL:
http://svn.apache.org/viewvc/webservices/sandesha/branches/sandesha2/java/1_3/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/AckRequestedProcessor.java?rev=578811&r1=578810&r2=578811&view=diff
==============================================================================
---
webservices/sandesha/branches/sandesha2/java/1_3/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/AckRequestedProcessor.java
(original)
+++
webservices/sandesha/branches/sandesha2/java/1_3/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/AckRequestedProcessor.java
Mon Sep 24 06:38:47 2007
@@ -36,7 +36,6 @@
import org.apache.axis2.description.AxisOperation;
import org.apache.axis2.engine.AxisEngine;
import org.apache.axis2.transport.TransportUtils;
-import org.apache.axis2.util.MessageContextBuilder;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.sandesha2.RMMsgContext;
@@ -162,18 +161,6 @@
//creating the ack message. If the ackRequest was a standalone
this will be a out (response) message
MessageContext ackMsgCtx = null;
- //checking whether this is an standalone ack message.
- boolean standAloneAck = false;
- String action = msgContext.getOptions().getAction();
- if (action!=null &&
-
Sandesha2Constants.SPEC_2007_02.Actions.ACTION_ACK_REQUEST.equals(action))
- standAloneAck = true;
-
- if (standAloneAck)
- ackMsgCtx
=MessageContextBuilder.createOutMessageContext (msgContext);
- else
- ackMsgCtx =
SandeshaUtil.createNewRelatedMessageContext(rmMsgCtx, ackOperation);
-
//setting up the RMMsgContext
RMMsgContext ackRMMsgCtx =
MsgInitializer.initializeMessage(ackMsgCtx);
ackRMMsgCtx.setRMNamespaceValue(rmMsgCtx.getRMNamespaceValue());
@@ -190,9 +177,6 @@
throw new SandeshaException(e3.getMessage());
}
- if (!standAloneAck)
- ackMsgCtx.setTo(acksTo);
-
ackMsgCtx.setReplyTo(msgContext.getTo());
RMMsgCreator.addAckMessage(ackRMMsgCtx, sequenceId, rmdBean);
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
