svn commit: r943457 - in /synapse/trunk/java/modules/core/src/main/java/org/apache/synapse: config/xml/ConditionalRouterMediatorFactory.java config/xml/ConditionalRouterMediatorSerializer.java mediators/eip/Target.java

[su...@apache.org]

Author: supun
Date: Wed May 12 11:49:01 2010
New Revision: 943457

URL: http://svn.apache.org/viewvc?rev=943457&view=rev
Log:
adding a getter to target to access the asynchronous property

Modified:
    synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/ConditionalRouterMediatorFactory.java
    synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/ConditionalRouterMediatorSerializer.java
    synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/eip/Target.java

Modified: synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/ConditionalRouterMediatorFactory.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/ConditionalRouterMediatorFactory.java?rev=943457&r1=943456&r2=943457&view=diff
==============================================================================
--- synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/ConditionalRouterMediatorFactory.java (original)
+++ synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/ConditionalRouterMediatorFactory.java Wed May 12 11:49:01 2010
@@ -22,7 +22,6 @@ package org.apache.synapse.config.xml;
 import org.apache.axiom.om.OMElement;
 import org.apache.axis2.util.JavaUtils;
 import org.apache.synapse.Mediator;
-import org.apache.synapse.SynapseException;
 import org.apache.synapse.commons.evaluators.Evaluator;
 import org.apache.synapse.commons.evaluators.EvaluatorException;
 import org.apache.synapse.commons.evaluators.config.EvaluatorFactoryFinder;
@@ -69,7 +68,8 @@ public class ConditionalRouterMediatorFa
         if (elem.getAttribute(CONTINUE_AFTER_ATTR) != null) {
             if (JavaUtils.isTrueExplicitly(elem.getAttributeValue(CONTINUE_AFTER_ATTR).trim())) {
                 conditionalRouterMediator.setContinueAfter(true);
-            } else if (JavaUtils.isFalseExplicitly(elem.getAttributeValue(CONTINUE_AFTER_ATTR).trim())) {
+            } else if (JavaUtils.isFalseExplicitly(
+                    elem.getAttributeValue(CONTINUE_AFTER_ATTR).trim())) {
                 conditionalRouterMediator.setContinueAfter(false);
             } else {
                 handleException("continueAfter attribute value of the conditionalRouter must " +

Modified: synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/ConditionalRouterMediatorSerializer.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/ConditionalRouterMediatorSerializer.java?rev=943457&r1=943456&r2=943457&view=diff
==============================================================================
--- synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/ConditionalRouterMediatorSerializer.java (original)
+++ synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/ConditionalRouterMediatorSerializer.java Wed May 12 11:49:01 2010
@@ -78,6 +78,10 @@ public class ConditionalRouterMediatorSe
                 handleException("Route in a conditional router has to have a target");
             }
 
+            if (route.getTarget().isAsynchronous()) {
+                routeElem.addAttribute(fac.createOMAttribute("asynchronous", nullNS, "true"));
+            }
+
             conditionalRouterElem.addChild(routeElem);
         }
 

Modified: synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/eip/Target.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/eip/Target.java?rev=943457&r1=943456&r2=943457&view=diff
==============================================================================
--- synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/eip/Target.java (original)
+++ synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/eip/Target.java Wed May 12 11:49:01 2010
@@ -32,7 +32,8 @@ import org.apache.axis2.addressing.Endpo
  * as used by common EIP mediators
  */
 public class Target {
-
+    private static final Log log = LogFactory.getLog(Target.class);
+    
     /** An optional To address to be set on the message when handing over to the target */
     private String toAddress = null;
 
@@ -51,10 +52,10 @@ public class Target {
     /** The target endpoint reference key */
     private String endpointRef = null;
 
+    /** if true the mediation will happen in a different thread than the original
+     * thread invoked the mediate method*/
     private boolean asynchronous = true;
 
-    private static final Log log = LogFactory.getLog(Target.class);
-
     /**
      * process the message through this target (may be to mediate
      * using the target sequence, send message to the target endpoint or both)
@@ -206,4 +207,8 @@ public class Target {
     public void setAsynchronous(boolean asynchronous) {
         this.asynchronous = asynchronous;
     }
+
+    public boolean isAsynchronous() {
+        return asynchronous;
+    }
 }
\ No newline at end of file