Discussion:
[mule-scm] [mule][24114] branches/mule-3.x/core/src/main/java/org/mule/processor: Change DefaultMuleEvent.isTransacted() to return null if there' s a transaction in context
Daniel Feist
2012-03-21 18:45:18 UTC
Permalink
There might be other places where you need to add event.isTransacted();

I cleaned up up all of this, when i put everything inside the resolution of sync in DefaultMuleEvent.

Dan
Revision
24114
Author
pablo.lagreca
Date
2012-03-21 13:36:16 -0500 (Wed, 21 Mar 2012)
Log Message
Change DefaultMuleEvent.isTransacted() to return null if there's a transaction in context
Modified Paths
branches/mule-3.x/core/src/main/java/org/mule/processor/LaxAsyncInterceptingMessageProcessor.java
branches/mule-3.x/core/src/main/java/org/mule/processor/LaxSedaStageInterceptingMessageProcessor.java
Diff
Modified: branches/mule-3.x/core/src/main/java/org/mule/processor/LaxAsyncInterceptingMessageProcessor.java (24113 => 24114)
--- branches/mule-3.x/core/src/main/java/org/mule/processor/LaxAsyncInterceptingMessageProcessor.java 2012-03-21 17:32:17 UTC (rev 24113)
+++ branches/mule-3.x/core/src/main/java/org/mule/processor/LaxAsyncInterceptingMessageProcessor.java 2012-03-21 18:36:16 UTC (rev 24114)
@@ -32,7 +32,7 @@
protected boolean isProcessAsync(MuleEvent event) throws MessagingException
{
- return doThreading && !event.isSynchronous();
+ return doThreading && !event.isSynchronous() && !event.isTransacted();
}
}
Modified: branches/mule-3.x/core/src/main/java/org/mule/processor/LaxSedaStageInterceptingMessageProcessor.java (24113 => 24114)
--- branches/mule-3.x/core/src/main/java/org/mule/processor/LaxSedaStageInterceptingMessageProcessor.java 2012-03-21 17:32:17 UTC (rev 24113)
+++ branches/mule-3.x/core/src/main/java/org/mule/processor/LaxSedaStageInterceptingMessageProcessor.java 2012-03-21 18:36:16 UTC (rev 24114)
@@ -46,6 +46,6 @@
@Override
protected boolean isProcessAsync(MuleEvent event) throws MessagingException
{
- return doThreading && !event.isSynchronous();
+ return doThreading && !event.isSynchronous() && !event.isTransacted();
}
}
http://xircles.codehaus.org/manage_email
Loading...