svn commit: r582522 - in /webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse: core/axis2/Axis2SynapseEnvironment.java mediators/eip/Target.java

[ruwan]

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: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]