Author: davsclaus Date: Sun Nov 14 08:46:53 2010 New Revision: 1034956 URL: http://svn.apache.org/viewvc?rev=1034956&view=rev Log: Fixed exception during stopping about concurrent access to hash map
Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/component/direct/DirectComponent.java Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/component/direct/DirectComponent.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/component/direct/DirectComponent.java?rev=1034956&r1=1034955&r2=1034956&view=diff ============================================================================== --- camel/trunk/camel-core/src/main/java/org/apache/camel/component/direct/DirectComponent.java (original) +++ camel/trunk/camel-core/src/main/java/org/apache/camel/component/direct/DirectComponent.java Sun Nov 14 08:46:53 2010 @@ -44,7 +44,7 @@ public class DirectComponent extends Def @Override protected void doStop() throws Exception { - ServiceHelper.stopService(consumers.values()); + ServiceHelper.stopServices(consumers); consumers.clear(); super.doStop(); }