Author: mckierna
Date: Tue Nov 20 03:00:18 2007
New Revision: 596611
URL: http://svn.apache.org/viewvc?rev=596611&view=rev
Log:
enable messages to override unreliable operations
Modified:
webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/util/SandeshaUtil.java
Modified:
webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/util/SandeshaUtil.java
URL:
http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/util/SandeshaUtil.java?rev=596611&r1=596610&r2=596611&view=diff
==============================================================================
---
webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/util/SandeshaUtil.java
(original)
+++
webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/util/SandeshaUtil.java
Tue Nov 20 03:00:18 2007
@@ -1101,14 +1101,18 @@
if(log.isDebugEnabled()) log.debug("Entry:
SandeshaUtil::isMessageUnreliable");
boolean result = false;
- //look at the msg ctx first
+ //look at the msg ctx first. It is either forced on or off at
the msg ctx level
String unreliable = (String)
mc.getProperty(SandeshaClientConstants.UNRELIABLE_MESSAGE);
if ("true".equals(unreliable)) {
if (log.isDebugEnabled()) log.debug("Unreliable message
context");
result = true;
- }
-
- if(!result) {
+ }
+ else if("false".equals(unreliable)){
+ //a forced reliable message
+ if (log.isDebugEnabled()) log.debug("Forced reliable
message context");
+ result = false;
+ }
+ else if(!result) {
//look at the operation
if (mc.getAxisOperation() != null) {
Parameter unreliableParam =
mc.getAxisOperation().getParameter(SandeshaClientConstants.UNRELIABLE_MESSAGE);
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
