You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ni...@apache.org on 2015/04/21 15:43:58 UTC
camel git commit: CAMEL-8673 Fix the concurrentModificationException
when creating dynamic routes with thanks to Dirk
Repository: camel
Updated Branches:
refs/heads/master c68683763 -> 381d53657
CAMEL-8673 Fix the concurrentModificationException when creating dynamic routes with thanks to Dirk
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/381d5365
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/381d5365
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/381d5365
Branch: refs/heads/master
Commit: 381d53657f972ea03f6a3784c6bd42322c57551d
Parents: c686837
Author: Willem Jiang <wi...@gmail.com>
Authored: Tue Apr 21 21:41:52 2015 +0800
Committer: Willem Jiang <wi...@gmail.com>
Committed: Tue Apr 21 21:43:29 2015 +0800
----------------------------------------------------------------------
.../src/main/java/org/apache/camel/impl/DefaultCamelContext.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/381d5365/camel-core/src/main/java/org/apache/camel/impl/DefaultCamelContext.java
----------------------------------------------------------------------
diff --git a/camel-core/src/main/java/org/apache/camel/impl/DefaultCamelContext.java b/camel-core/src/main/java/org/apache/camel/impl/DefaultCamelContext.java
index bbc3377..bc5ca4f 100644
--- a/camel-core/src/main/java/org/apache/camel/impl/DefaultCamelContext.java
+++ b/camel-core/src/main/java/org/apache/camel/impl/DefaultCamelContext.java
@@ -814,13 +814,13 @@ public class DefaultCamelContext extends ServiceSupport implements ModelCamelCon
}
void removeRouteCollection(Collection<Route> routes) {
- synchronized (routes) {
+ synchronized (this.routes) {
this.routes.removeAll(routes);
}
}
void addRouteCollection(Collection<Route> routes) throws Exception {
- synchronized (routes) {
+ synchronized (this.routes) {
this.routes.addAll(routes);
}
}