synapse-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ru...@apache.org
Subject svn commit: r582522 - in /webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse: core/axis2/Axis2SynapseEnvironment.java mediators/eip/Target.java
Date Sat, 06 Oct 2007 17:49:23 GMT
Author: ruwan
Date: Sat Oct  6 10:49:22 2007
New Revision: 582522

URL: http://svn.apache.org/viewvc?rev=582522&view=rev
Log:
Fixing an issue with clone mediator after making cloned messages to run asynchronously.

Modified:
    webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/Axis2SynapseEnvironment.java
    webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/eip/Target.java

Modified: webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/Axis2SynapseEnvironment.java
URL: http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/Axis2SynapseEnvironment.java?rev=582522&r1=582521&r2=582522&view=diff
==============================================================================
--- webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/Axis2SynapseEnvironment.java
(original)
+++ webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/core/axis2/Axis2SynapseEnvironment.java
Sat Oct  6 10:49:22 2007
@@ -123,7 +123,7 @@
     public void injectAsync(final MessageContext synCtx, SequenceMediator seq) {
         if (log.isDebugEnabled()) {
             log.debug("Injecting MessageContext for asynchronous mediation using the "
-                + seq.getName() == null? "Anonymous" : seq.getName());
+                + (seq.getName() == null? "Anonymous" : seq.getName()) + " Sequence");
         }
         synCtx.setEnvironment(this);
         // todo: do we need to have this in here ? ruwan

Modified: webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/eip/Target.java
URL: http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/eip/Target.java?rev=582522&r1=582521&r2=582522&view=diff
==============================================================================
--- webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/eip/Target.java
(original)
+++ webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/eip/Target.java
Sat Oct  6 10:49:22 2007
@@ -63,11 +63,11 @@
     /**
      * This method will be called by the EIP mediators to mediated the target (may be to
mediate
      * using the target sequence, send message to the target endpoint or both)
-     * 
+     *
      * @param synCtx - MessageContext to be mediated
      * @return boolean true if the sequence does not drop the message, false if it does
      */
-    public boolean mediate(MessageContext synCtx) {
+    public void mediate(MessageContext synCtx) {
 
         if (soapAction != null) {
             synCtx.setSoapAction(soapAction);
@@ -82,11 +82,11 @@
         }
 
         if (sequence != null) {
-            return sequence.mediate(synCtx);
+            synCtx.getEnvironment().injectAsync(synCtx, sequence);
         } else if (sequenceRef != null) {
-            Mediator refSequence = synCtx.getConfiguration().getSequence(sequenceRef);
+            SequenceMediator refSequence = (SequenceMediator) synCtx.getConfiguration().getSequence(sequenceRef);
             if (refSequence != null) {
-                return refSequence.mediate(synCtx);
+                synCtx.getEnvironment().injectAsync(synCtx, refSequence);
             }
         }
 
@@ -97,11 +97,8 @@
             if (epr != null) {
                 epr.send(synCtx);
             }
-        } else {
-            synCtx.getEnvironment().injectMessage(synCtx);
         }
 
-        return true;
     }
 
     ///////////////////////////////////////////////////////////////////////////////////////



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


Mime
View raw message