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/10/06 19:49:23 UTC
svn commit: r582522 - in
/webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse:
core/axis2/Axis2SynapseEnvironment.java mediators/eip/Target.java
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