codehaus


[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Re: SynchronizedExchange: Exception occurred during onCompletion


Hi,
I'm a fabryprog colleague, our version is v2.20.4 we tried only on this version because we cannot reproduce this warning in our internal tests.

Thanks a lot,
Fabrizio

________________________________
Da: Claus Ibsen <claus.ibsen@xxxxxxxxx>
Inviato: martedì 18 dicembre 2018 15:56
A: users@xxxxxxxxxxxxxxxx
Oggetto: Re: SynchronizedExchange: Exception occurred during onCompletion

What version of Camel do you use? And have you tried with a newer version

On Tue, Dec 18, 2018 at 3:44 PM FabryProg <fabryprog@xxxxxxxxx> wrote:
>
> Hello
>
> Occasionally, we have a WARNING into our camel project.
>
> We are using disruptor queue implementation
>
> what should it be? Is it an error or warning message? is it dangerous?
>
> we cannot reproduce it programmatically!
>
> Thanks
>
> 2018-12-16 19:13:44,638 WARN
> [org.apache.camel.component.disruptor.SynchronizedExchange] - <Exception
> occurred during onCompletion. This exception will be ignored.> ()
> java.util.ConcurrentModificationException
>     at java.util.HashMap$HashIterator.nextNode(HashMap.java:1442)
>     at java.util.HashMap$EntryIterator.next(HashMap.java:1476)
>     at java.util.HashMap$EntryIterator.next(HashMap.java:1474)
>     at java.util.HashMap.putMapEntries(HashMap.java:512)
>     at java.util.HashMap.putAll(HashMap.java:785)
>     at
> org.apache.camel.util.ExchangeHelper.copyResults(ExchangeHelper.java:379)
>     at
> org.apache.camel.component.disruptor.SingleConsumerSynchronizedExchange.consumed(SingleConsumerSynchronizedExchange.java:33)
>     at
> org.apache.camel.component.disruptor.DisruptorConsumer$2.onComplete(DisruptorConsumer.java:164)
>     at
> org.apache.camel.util.UnitOfWorkHelper.doneSynchronizations(UnitOfWorkHelper.java:104)
>     at
> org.apache.camel.component.disruptor.AbstractSynchronizedExchange.performSynchronization(AbstractSynchronizedExchange.java:55)
>     at
> org.apache.camel.component.disruptor.SingleConsumerSynchronizedExchange.consumed(SingleConsumerSynchronizedExchange.java:35)
>     at
> org.apache.camel.component.disruptor.DisruptorConsumer$2.onComplete(DisruptorConsumer.java:164)
>     at
> org.apache.camel.util.UnitOfWorkHelper.doneSynchronizations(UnitOfWorkHelper.java:104)
>     at
> org.apache.camel.impl.DefaultUnitOfWork.done(DefaultUnitOfWork.java:243)
>     at
> org.apache.camel.util.UnitOfWorkHelper.doneUow(UnitOfWorkHelper.java:65)
>     at
> org.apache.camel.processor.CamelInternalProcessor$UnitOfWorkProcessorAdvice.after(CamelInternalProcessor.java:685)
>     at
> org.apache.camel.processor.CamelInternalProcessor$UnitOfWorkProcessorAdvice.after(CamelInternalProcessor.java:634)
>     at
> org.apache.camel.processor.CamelInternalProcessor$InternalCallback.done(CamelInternalProcessor.java:251)
>     at org.apache.camel.processor.Pipeline.process(Pipeline.java:127)
>     at
> org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:201)
>     at
> org.apache.camel.component.disruptor.DisruptorConsumer.process(DisruptorConsumer.java:175)
>     at
> org.apache.camel.component.disruptor.DisruptorConsumer.access$000(DisruptorConsumer.java:42)
>     at
> org.apache.camel.component.disruptor.DisruptorConsumer$ConsumerEventHandler.onEvent(DisruptorConsumer.java:213)
>     at
> org.apache.camel.component.disruptor.DisruptorConsumer$ConsumerEventHandler.onEvent(DisruptorConsumer.java:193)
>     at
> com.lmax.disruptor.BatchEventProcessor.run(BatchEventProcessor.java:129)
>     at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
>     at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
>     at java.lang.Thread.run(Thread.java:748)



--
Claus Ibsen
-----------------
http://davsclaus.com @davsclaus
Camel in Action 2: https://www.manning.com/ibsen2