ConcurrentModificationException on seda consumer

[Thibaut Robert <th...@gmail.com>]

Hi,

I have a simple route consuming from a seda and sending to an akka Actor
(with akka-camel).
On heavy load, I got the following error:

java.util.ConcurrentModificationException: null
at java.util.TreeMap$PrivateEntryIterator.nextEntry(TreeMap.java:1207)
~[na:1.8.0_45-internal]
at java.util.TreeMap$EntryIterator.next(TreeMap.java:1243)
~[na:1.8.0_45-internal]
at java.util.TreeMap$EntryIterator.next(TreeMap.java:1238)
~[na:1.8.0_45-internal]
at java.util.TreeMap.buildFromSorted(TreeMap.java:2555)
~[na:1.8.0_45-internal]
at java.util.TreeMap.buildFromSorted(TreeMap.java:2504)
~[na:1.8.0_45-internal]
at java.util.TreeMap.putAll(TreeMap.java:319) ~[na:1.8.0_45-internal]
at org.apache.camel.impl.MessageSupport.copyFrom(MessageSupport.java:151)
~[camel-core-2.15.3.jar:2.15.3]
at org.apache.camel.impl.MessageSupport.copy(MessageSupport.java:124)
~[camel-core-2.15.3.jar:2.15.3]
at
org.apache.camel.component.seda.SedaConsumer.doRun(SedaConsumer.java:203)
[camel-core-2.15.3.jar:2.15.3]
at org.apache.camel.component.seda.SedaConsumer.run(SedaConsumer.java:147)
[camel-core-2.15.3.jar:2.15.3]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
[na:1.8.0_45-internal]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
[na:1.8.0_45-internal]
at java.lang.Thread.run(Thread.java:745) [na:1.8.0_45-internal]

Looking at the source of SedaConsumer, I suspect an issue with this code
(line 197-206):

                        // send a new copied exchange with new camel context
                        Exchange newExchange = prepareExchange(exchange);
                        // process the exchange
                        sendToConsumers(newExchange);
                        // copy the message back
                        if (newExchange.hasOut()) {
                            exchange.setOut(newExchange.getOut().copy());
                        } else {
                            exchange.setIn(newExchange.getIn());
                        }

sendToConsumers will not block if the route is asynchronous (which is my
case). The copy of the out message is done concurrently while the message
is processing.

Is it a bug or am i missing something ?

Thanks,
Thibaut