You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ge...@apache.org on 2008/09/15 18:18:41 UTC
svn commit: r695529 - in
/activemq/camel/trunk/camel-core/src/main/java/org/apache/camel:
processor/MulticastProcessor.java util/concurrent/AtomicExchange.java
Author: gertv
Date: Mon Sep 15 09:18:40 2008
New Revision: 695529
URL: http://svn.apache.org/viewvc?rev=695529&view=rev
Log:
CAMEL-876: Fixing concurrency issue (hopefully)
Modified:
activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/MulticastProcessor.java
activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/util/concurrent/AtomicExchange.java
Modified: activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/MulticastProcessor.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/MulticastProcessor.java?rev=695529&r1=695528&r2=695529&view=diff
==============================================================================
--- activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/MulticastProcessor.java (original)
+++ activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/MulticastProcessor.java Mon Sep 15 09:18:40 2008
@@ -162,10 +162,10 @@
completedExchanges.increment();
ProcessCall call = new ProcessCall(subExchange, producer, new AsyncCallback() {
public void done(boolean doneSynchronously) {
- completedExchanges.decrement();
if (streaming && aggregationStrategy != null) {
doAggregate(result, subExchange);
}
+ completedExchanges.decrement();
}
});
Modified: activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/util/concurrent/AtomicExchange.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/util/concurrent/AtomicExchange.java?rev=695529&r1=695528&r2=695529&view=diff
==============================================================================
--- activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/util/concurrent/AtomicExchange.java (original)
+++ activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/util/concurrent/AtomicExchange.java Mon Sep 15 09:18:40 2008
@@ -22,8 +22,6 @@
/**
* Convenience class for holding an {@link Exchange} in a thread-safe way
- * @author gert
- *
*/
@SuppressWarnings("serial")
public class AtomicExchange extends AtomicReference<Exchange> {