ConcurrentModificationException in ThreadProcessor
--------------------------------------------------

                 Key: CAMEL-715
                 URL: https://issues.apache.org/activemq/browse/CAMEL-715
             Project: Apache Camel
          Issue Type: Bug
          Components: camel-core
            Reporter: Wojciech Durczynski
            Priority: Critical
             Fix For: 1.4.0


When defining very simple routing with ThreadProcessor I get 
ConcurrentModificationException on multicore systems.

Example:
 from("direct:a").thread(10).process(new Processor() {

          @Override
          public void process(Exchange ex) throws Exception {
            //sth
          }
});

Stack trace:
Exception in thread "Thread Processor"
java.util.ConcurrentModificationException
        at java.util.HashMap$HashIterator.nextEntry(HashMap.java:793)
        at java.util.HashMap$EntryIterator.next(HashMap.java:834)
        at java.util.HashMap$EntryIterator.next(HashMap.java:832)
        at java.util.HashMap.putAll(HashMap.java:523)
        at
org.apache.camel.processor.Pipeline.createNextExchange(Pipeline.java:146
)
        at org.apache.camel.processor.Pipeline$1.done(Pipeline.java:123)
        at
org.apache.camel.processor.ThreadProcessor$ProcessCall.run(ThreadProcess
or.j
ava:66)
        at
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecuto
r.ja
va:885)
        at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.ja
va:9
07)
        at java.lang.Thread.run(Thread.java:619)




-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.

Reply via email to