svn commit: r997582 - in /synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml: TargetFactory.java TargetSerializer.java

[supun]

Author: supun
Date: Thu Sep 16 03:47:30 2010
New Revision: 997582

URL: http://svn.apache.org/viewvc?rev=997582&view=rev
Log:
giving capability to implement target in sequencial mode

Modified:
    
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/TargetFactory.java
    
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/TargetSerializer.java

Modified: 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/TargetFactory.java
URL: 
http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/TargetFactory.java?rev=997582&r1=997581&r2=997582&view=diff
==============================================================================
--- 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/TargetFactory.java
 (original)
+++ 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/TargetFactory.java
 Thu Sep 16 03:47:30 2010
@@ -87,6 +87,19 @@ public class TargetFactory {
             target.setEndpointRef(endpointAttr.getAttributeValue());
         }
 
+        OMAttribute syncAttribute = elem.getAttribute(
+                new QName(XMLConfigConstants.NULL_NAMESPACE, "sequencial"));
+        if (syncAttribute != null) {
+            if (syncAttribute.getAttributeValue().equals("true")) {
+                target.setAsynchronous(false);
+            } else if (syncAttribute.getAttributeValue().equals("false")) {
+                target.setAsynchronous(true);
+            } else {
+                handleException("Only true or false expected for Target 
sequencial " +
+                        "attribute, specified value is: " + 
syncAttribute.getAttributeValue());
+            }
+        }
+
         OMElement sequence = elem.getFirstChildWithName(
                 new QName(XMLConfigConstants.SYNAPSE_NAMESPACE, "sequence"));
         if (sequence != null) {

Modified: 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/TargetSerializer.java
URL: 
http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/TargetSerializer.java?rev=997582&r1=997581&r2=997582&view=diff
==============================================================================
--- 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/TargetSerializer.java
 (original)
+++ 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/config/xml/TargetSerializer.java
 Thu Sep 16 03:47:30 2010
@@ -75,6 +75,10 @@ public class TargetSerializer {
             targetElem.addAttribute("endpoint", target.getEndpointRef(), 
nullNS);
         }
 
+        if (!target.isAsynchronous()) {
+            targetElem.addAttribute("sequencial", "true", nullNS);
+        }
+
         if (target.getSequence() != null) {
             SequenceMediatorSerializer serializer = new 
SequenceMediatorSerializer();
             serializer.serializeAnonymousSequence(targetElem, 
target.getSequence());