Which version of Camel are you using ?
I just assume you are using Camel 2.3.0,  as Claus did lots of work on Camel
trunk, the stack trace can't match with current trunk code.

If I remember right , there is a timer thread to keep try redelivering the
exchange, maybe that cause the ConcurrentModificationException.

Can try to run your application with Camel 2.4-SNAPSHOT ?
If the error still there, you can fill a JIRA and submit a small test case,
so we can keep on digging it.

Willem
----------------------------------
Apache Camel, Apache CXF committer
Open SOA http://www.fusesource.com
Blog http://willemjiang.blogspot.com
Tiwtter http://twitter.com/willemjiang 


Ryan R. wrote:
> 
> I have the following route defined in camel:
> from("jms:queue:syncTopic").process(new
> ResequenceProcessorStageOne(syncSession)).throttle(10).resequence(header("messageOrder")).stream().capacity(1000).timeout(100L).unmarshal(format).to("trex");
> 
> I am getting the below exception whenever I add in the resequencer? Any
> thoughts as to what may be causing this? Does the jms-component need to be
> configured to act as a single threaded listener?
> 
> The reason I have a resequencer hooked up to ActiveMQ is because of the
> following bug:
> https://issues.apache.org/activemq/browse/AMQ-2780
> 
> 
> [hread 0 - Resequencer Delivery] DefaultErrorHandler            ERROR
> Failed delivery for exchangeId:
> ID:RSI-KAU-RROLND-4962-1278128211066-0:0:1:1:59. Exhausted after delivery
> attempt: 1 caught: java.util.ConcurrentModificationException
> java.util.ConcurrentModificationException
>       at java.util.HashMap$HashIterator.nextEntry(HashMap.java:793)
>       at java.util.HashMap$KeyIterator.next(HashMap.java:828)
>       at
> org.apache.camel.util.CaseInsensitiveMap.putAll(CaseInsensitiveMap.java:86)
>       at 
> org.apache.camel.component.jms.JmsMessage.copyFrom(JmsMessage.java:77)
>       at
> org.apache.camel.processor.UnmarshalProcessor.process(UnmarshalProcessor.java:49)
>       at
> org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:67)
>       at
> org.apache.camel.processor.DelegateProcessor.processNext(DelegateProcessor.java:53)
>       at
> org.apache.camel.processor.DelegateProcessor.proceed(DelegateProcessor.java:82)
>       at
> org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:97)
>       at
> org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:67)
>       at
> org.apache.camel.processor.RedeliveryErrorHandler.processExchange(RedeliveryErrorHandler.java:185)
>       at
> org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:151)
>       at
> org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:89)
>       at
> org.apache.camel.processor.DefaultErrorHandler.process(DefaultErrorHandler.java:49)
>       at
> org.apache.camel.processor.DefaultChannel.process(DefaultChannel.java:228)
>       at org.apache.camel.processor.Pipeline.process(Pipeline.java:75)
>       at
> org.apache.camel.processor.StreamResequencer.sendElement(StreamResequencer.java:165)
>       at
> org.apache.camel.processor.StreamResequencer.sendElement(StreamResequencer.java:61)
>       at
> org.apache.camel.processor.resequencer.ResequencerEngine.deliverNext(ResequencerEngine.java:254)
>       at
> org.apache.camel.processor.resequencer.ResequencerEngine.deliver(ResequencerEngine.java:218)
>       at
> org.apache.camel.processor.StreamResequencer$Delivery.run(StreamResequencer.java:212)
> MessageID Out of Order: 59!=58
> 
> 
-- 
View this message in context: 
http://camel.465427.n5.nabble.com/Resequence-Stream-ConcurrentModificationException-tp524555p656523.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Reply via email to