In Red Hat Fuse, we encounter java.lang.IllegalStateException: Queue full at org.apache.camel.component.seda.SedaProducer.addToQueue(SedaProducer.java:262)

Issue

We encounter "Queue full" error messages when processing batch messages.

Camel (camel-1) thread #41 - "WireTap","app.name":"xxx-processor","app.version":"1.0","message":"xxx-processor | camel-1 | myApp | xxxxxx |
 java.lang.IllegalStateException: Queue full
    at java.util.AbstractQueue.add(AbstractQueue.java:98)
    at org.apache.camel.component.seda.SedaProducer.addToQueue(SedaProducer.java:262)
    at org.apache.camel.component.seda.SedaProducer.process(SedaProducer.java:167)
    at org.apache.camel.processor.SendDynamicProcessor$1.doInAsyncProducer(SendDynamicProcessor.java:178)
    at org.apache.camel.impl.ProducerCache.doInAsyncProducer(ProducerCache.java:445)
    at org.apache.camel.processor.SendDynamicProcessor.process(SendDynamicProcessor.java:160)
    at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:548)
    at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:201)
    at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:97)
    at org.apache.camel.processor.WireTapProcessor$1.call(WireTapProcessor.java:160)
    at org.apache.camel.processor.WireTapProcessor$1.call(WireTapProcessor.java:155)
    at java.util.concurrent.FutureTask.run(FutureTask.java:266)
    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)

The above error is reported from the particular route that retrieves unprocessed records ids from the database and sends each in a separate message to the designated queue .

...
.wireTap("seda:" + myRoute)
...

from("seda:" + myRoute)
    .process(new Processor() {
         @Override
         public void process(Exchange exchange) throws Exception {
               exchange.setOut(exchange.getIn());
               MyAppLoad myLoad = new MyAppLoad();
               exchange.getOut().setBody(myLoad);
            }
         })
         .recipientList(simple("bean:myDatabase?method=save"));