You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@synapse.apache.org by ru...@apache.org on 2007/12/06 05:55:31 UTC

svn commit: r601612 - in /webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse: mediators/eip/splitter/CloneMediator.java util/MessageHelper.java

Author: ruwan
Date: Wed Dec  5 20:55:30 2007
New Revision: 601612

URL: http://svn.apache.org/viewvc?rev=601612&view=rev
Log:
Minor fix to the clone MC method and adding generics to the CloneMediator

Modified:
    webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/eip/splitter/CloneMediator.java
    webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/util/MessageHelper.java

Modified: webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/eip/splitter/CloneMediator.java
URL: http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/eip/splitter/CloneMediator.java?rev=601612&r1=601611&r2=601612&view=diff
==============================================================================
--- webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/eip/splitter/CloneMediator.java (original)
+++ webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/eip/splitter/CloneMediator.java Wed Dec  5 20:55:30 2007
@@ -47,7 +47,7 @@
     /**
      * Holds the list of targets to which cloned copies of the message will be given for mediation
      */
-    private List targets = new ArrayList();
+    private List<Target> targets = new ArrayList<Target>();
 
     /**
      * This will implement the mediate method of the Mediator interface and will provide the
@@ -97,7 +97,7 @@
         OperationContext opCtx
             = ((Axis2MessageContext) synCtx).getAxis2MessageContext().getOperationContext();
         if (!continueParent && opCtx != null) {
-            opCtx.setProperty(Constants.RESPONSE_WRITTEN,"SKIP");
+            opCtx.setProperty(Constants.RESPONSE_WRITTEN, "SKIP");
         }
 
         // if continue parent is true mediators after the clone will be called for the further
@@ -114,7 +114,7 @@
      * @return MessageContext which is cloned from the given parameters
      */
     private MessageContext getClonedMessageContext(MessageContext synCtx, int messageSequence,
-        int messageCount) {
+                                                   int messageCount) {
 
         MessageContext newCtx = null;
         try {
@@ -125,8 +125,9 @@
         }
 
         // Sets the property MESSAGE_SEQUENCE to the MC for aggragation purposes 
-        newCtx.setProperty(EIPConstants.MESSAGE_SEQUENCE,
-            String.valueOf(messageSequence) + EIPConstants.MESSAGE_SEQUENCE_DELEMITER + messageCount);
+        assert newCtx != null;
+        newCtx.setProperty(EIPConstants.MESSAGE_SEQUENCE, String.valueOf(messageSequence)
+            + EIPConstants.MESSAGE_SEQUENCE_DELEMITER + messageCount);
 
         return newCtx;
     }
@@ -143,11 +144,11 @@
         this.continueParent = continueParent;
     }
 
-    public List getTargets() {
+    public List<Target> getTargets() {
         return targets;
     }
 
-    public void setTargets(List targets) {
+    public void setTargets(List<Target> targets) {
         this.targets = targets;
     }
 

Modified: webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/util/MessageHelper.java
URL: http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/util/MessageHelper.java?rev=601612&r1=601611&r2=601612&view=diff
==============================================================================
--- webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/util/MessageHelper.java (original)
+++ webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/util/MessageHelper.java Wed Dec  5 20:55:30 2007
@@ -95,7 +95,7 @@
         org.apache.axis2.context.MessageContext mc) throws AxisFault {
 
         org.apache.axis2.context.MessageContext newMC = clonePartially(mc);
-        newMC.setEnvelope(cloneSOAPEnvelope(cloneSOAPEnvelope(mc.getEnvelope())));
+        newMC.setEnvelope(cloneSOAPEnvelope(mc.getEnvelope()));
         
         newMC.setServiceContext(mc.getServiceContext());
         newMC.setOperationContext(mc.getOperationContext());



---------------------------------------------------------------------
To unsubscribe, e-mail: synapse-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: synapse-dev-help@ws.apache.org