You are viewing a plain text version of this content. The canonical link for it is here.
Posted to fx-dev@ws.apache.org by ch...@apache.org on 2006/08/31 09:53:43 UTC
svn commit: r438831 -
/webservices/sandesha/trunk/java/src/org/apache/sandesha2/handlers/SandeshaOutHandler.java
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: sandesha-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: sandesha-dev-help@ws.apache.org