Author: amilas
Date: Wed May 13 06:57:00 2009
New Revision: 774240
URL: http://svn.apache.org/viewvc?rev=774240&view=rev
Log:
Set a property for make connections and terminate response messages to send 202
accepted
header for synapse nhttp transport. Also increas the terminate message delay
time suite for nhttp transport
as well
Modified:
webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/Sandesha2Constants.java
webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/MakeConnectionProcessor.java
webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/TerminateSeqResponseMsgProcessor.java
Modified:
webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/Sandesha2Constants.java
URL:
http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/Sandesha2Constants.java?rev=774240&r1=774239&r2=774240&view=diff
==============================================================================
---
webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/Sandesha2Constants.java
(original)
+++
webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/Sandesha2Constants.java
Wed May 13 06:57:00 2009
@@ -537,7 +537,7 @@
int CLIENT_SLEEP_TIME = 10000;
- int TERMINATE_DELAY = 100;
+ int TERMINATE_DELAY = 500;
static final int TRANSPORT_WAIT_TIME = 60000;
Modified:
webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/MakeConnectionProcessor.java
URL:
http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/MakeConnectionProcessor.java?rev=774240&r1=774239&r2=774240&view=diff
==============================================================================
---
webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/MakeConnectionProcessor.java
(original)
+++
webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/MakeConnectionProcessor.java
Wed May 13 06:57:00 2009
@@ -233,6 +233,8 @@
} else {
if
(LoggingControl.isAnyTracingEnabled() && log.isDebugEnabled())
log.debug("Exit:
MakeConnectionProcessor::processInMessage, no matching message found");
+ // this property indicate
synapse nhttp transport to send a 202 Accepted header
+
rmMsgCtx.getMessageContext().setProperty("FORCE_SC_ACCEPTED",
Constants.VALUE_TRUE);
return false;
}
} else {
Modified:
webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/TerminateSeqResponseMsgProcessor.java
URL:
http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/TerminateSeqResponseMsgProcessor.java?rev=774240&r1=774239&r2=774240&view=diff
==============================================================================
---
webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/TerminateSeqResponseMsgProcessor.java
(original)
+++
webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/TerminateSeqResponseMsgProcessor.java
Wed May 13 06:57:00 2009
@@ -20,6 +20,7 @@
package org.apache.sandesha2.msgprocessors;
import org.apache.axis2.AxisFault;
+import org.apache.axis2.Constants;
import org.apache.axis2.context.ConfigurationContext;
import org.apache.axis2.context.MessageContext;
import org.apache.commons.logging.Log;
@@ -78,7 +79,8 @@
// Stop this message travelling further through the Axis runtime
terminateResRMMsg.pause();
-
+ // this property indicate synapse nhttp transport to send a 202
Accepted header
+ msgContext.setProperty("FORCE_SC_ACCEPTED",
Constants.VALUE_TRUE);
if(log.isDebugEnabled()) log.debug("Exit:
TerminateSeqResponseMsgProcessor::processInMessage " + Boolean.TRUE);
return true;
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
