You are viewing a plain text version of this content. The canonical link for it is here.
Posted to sandesha-dev@ws.apache.org by su...@apache.org on 2007/09/24 15:38:48 UTC
svn commit: r578811 -
/webservices/sandesha/branches/sandesha2/java/1_3/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/AckRequestedProcessor.java
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: sandesha-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: sandesha-dev-help@ws.apache.org