Author: chamikara
Date: Thu Aug 31 00:53:43 2006
New Revision: 438831
URL: http://svn.apache.org/viewvc?rev=438831&view=rev
Log:
Applied the patch from Thomas on unreliable messages.
Modified:
webservices/sandesha/trunk/java/src/org/apache/sandesha2/handlers/SandeshaOutHandler.java
Modified:
webservices/sandesha/trunk/java/src/org/apache/sandesha2/handlers/SandeshaOutHandler.java
URL:
http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/src/org/apache/sandesha2/handlers/SandeshaOutHandler.java?rev=438831&r1=438830&r2=438831&view=diff
==============================================================================
---
webservices/sandesha/trunk/java/src/org/apache/sandesha2/handlers/SandeshaOutHandler.java
(original)
+++
webservices/sandesha/trunk/java/src/org/apache/sandesha2/handlers/SandeshaOutHandler.java
Thu Aug 31 00:53:43 2006
@@ -24,6 +24,7 @@
import org.apache.axis2.context.MessageContext;
import org.apache.axis2.context.OperationContextFactory;
import org.apache.axis2.description.AxisService;
+import org.apache.axis2.description.Parameter;
import org.apache.axis2.handlers.AbstractHandler;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
@@ -69,11 +70,24 @@
throw new AxisFault(message);
}
- String unreliable = (String)
msgCtx.getProperty(SandeshaClientConstants.UNRELIABLE_MESSAGE);
- if (null != unreliable && "true".equals(unreliable)) {
- if (log.isDebugEnabled())
- log.debug("Exit: SandeshaOutHandler::invoke,
Skipping sandesha processing for unreliable message");
- return;
+ //see if this message is unreliable i.e. WSRM not requried
+ //look at the msg ctx first
+ {
+ String unreliable = (String)
msgCtx.getProperty(SandeshaClientConstants.UNRELIABLE_MESSAGE);
+ if (null != unreliable && "true".equals(unreliable)) {
+ if (log.isDebugEnabled())
+ log.debug("Exit:
SandeshaOutHandler::invoke, Skipping sandesha processing for unreliable
message");
+ return;
+ }
+ }
+ //look at the operation ctx
+ {
+ Parameter unreliable =
msgCtx.getAxisOperation().getParameter(SandeshaClientConstants.UNRELIABLE_MESSAGE);
+ if (null != unreliable &&
"true".equals(unreliable.getValue())) {
+ if (log.isDebugEnabled())
+ log.debug("Exit:
SandeshaOutHandler::invoke, Skipping sandesha processing for unreliable
message");
+ return;
+ }
}
String DONE = (String)
msgCtx.getProperty(Sandesha2Constants.APPLICATION_PROCESSING_DONE);
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
