You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@synapse.apache.org by su...@apache.org on 2010/04/02 07:02:19 UTC
svn commit: r930164 -
/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/builtin/EnqueueMediator.java
Author: supun
Date: Fri Apr 2 05:02:19 2010
New Revision: 930164
URL: http://svn.apache.org/viewvc?rev=930164&view=rev
Log:
Using a existing worker
Modified:
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/builtin/EnqueueMediator.java
Modified: synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/builtin/EnqueueMediator.java
URL: http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/builtin/EnqueueMediator.java?rev=930164&r1=930163&r2=930164&view=diff
==============================================================================
--- synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/builtin/EnqueueMediator.java (original)
+++ synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/builtin/EnqueueMediator.java Fri Apr 2 05:02:19 2010
@@ -20,13 +20,13 @@
package org.apache.synapse.mediators.builtin;
import org.apache.synapse.mediators.AbstractMediator;
+import org.apache.synapse.mediators.MediatorWorker;
import org.apache.synapse.mediators.base.SequenceMediator;
import org.apache.synapse.MessageContext;
import org.apache.synapse.Mediator;
import org.apache.synapse.SynapseLog;
import org.apache.synapse.commons.executors.PriorityExecutor;
import org.apache.synapse.core.axis2.Axis2MessageContext;
-import org.apache.synapse.executors.SequenceWorker;
/**
* This mediator execute a given sequence with a given priority.
@@ -60,9 +60,8 @@ public class EnqueueMediator extends Abs
Mediator m = synCtx.getSequence(sequenceName);
if (m != null && m instanceof SequenceMediator) {
-
- SequenceWorker worker = new SequenceWorker(synCtx, m);
-
+ MediatorWorker worker = new MediatorWorker(m, synCtx);
+ // execute with the given priority
executor.execute(worker, priority);
// with the nio transport, this causes the listener not to write a 202