Hi
Okay so this is working correctly in Camel, its because you do not
specify in the route when you send to part2 that it should block
.to("seda://part2?blockWhenFull=true");
And when you use spring boot you can also pre configure the seda
component to block by default such as
@Bean
SedaComponent seda(CamelContext context) {
SedaComponent seda = context.getComponent("seda", SedaComponent.class);
seda.setDefaultBlockWhenFull(true);
return seda;
}
Or set this in the application.properties where you can configure this too
On Wed, Feb 16, 2022 at 2:43 PM Claus Ibsen <claus.ib...@gmail.com> wrote:
>
> Hi
>
> That is weird as we use the JDK api for the queue that has put and
> add, where put will block until there is free space, and add has the
> timeout.
> See the source code in SedaProducer.
>
> So if offerTimeout = 0 (defaut) then it uses put which should wait.
>
> I wonder if somehow the offerTineout mistakenly gets set to -1 or
> something so you end up with the add method that throws the exception
>
> On Thu, Feb 3, 2022 at 5:33 PM Craig Taylor <ctalk...@ctalkobt.net> wrote:
> >
> > I've got a scenario where I need to iterate through all users within a
> > system and send them to a remote as part of a routine "sync" to ensure that
> > both systems are in agreement.
> >
> > User imports are also supported so there is some initial aggregation done
> > on id in an attempt to minimize updates to the 3rd party system. It's ok
> > to send duplicates over, just not ideal so the initial aggregation has a
> > size / timeout based aggregation.
> >
> > The 3rd party system (2nd step) is intended to aggregate and send those
> > updates in fixed size batches. Changing it to a simple "mock:blah"
> > doesn't change behavior at this point.
> >
> > I'm running into issues when sending to the initial seda queue (see
> > attached github example) and getting a queue full. This occurs even when
> > I'm attempting to use blockWhenFull and other parameters.
> >
> > Github at https://github.com/CTalkobt/issues . (ref structure - Only
> > specific to this issue at this point; M
> > urphy will expand it in the future.)
> >
> > Route is :
> >
> > > from("seda://incoming")
> > > .routeId("incoming")
> > > .aggregate(simple("${body.id}"),
> > > AggregationStrategies.flexible().accumulateInCollection(ArrayList.class) )
> > > .completionSize(100)
> > > .completionTimeout(500)
> > > .process(exch -> logger.info("incoming 1:" +
> > > exch.getIn().getBody()))
> > > .to("seda://part2");
> >
> >
> > from("seda://part2")
> > .aggregate(constant(1),
> > AggregationStrategies.flexible().accumulateInCollection(ArrayList.class))
> >
> > .completionTimeout(500)
> > .completionSize(500)
> > .process(exch -> logger.info("Got : " +
> > exch.getIn().getBody(List.class).size()) );
> > }
> >
> > Stack trace:
> >
> > > org.apache.camel.CamelExecutionException: Exception occurred during
> > > execution on the exchange: Exchange[99618F8E0720C3E-00000000000003E8]
> > > at
> > > org.apache.camel.CamelExecutionException.wrapCamelExecutionException(CamelExecutionException.java:45)
> > > ~[camel-api-3.14.1.jar:3.14.1]
> > > at
> > > org.apache.camel.support.ExchangeHelper.extractResultBody(ExchangeHelper.java:687)
> > > ~[camel-support-3.14.1.jar:3.14.1]
> > > at
> > > org.apache.camel.impl.engine.DefaultProducerTemplate.extractResultBody(DefaultProducerTemplate.java:591)
> > > ~[camel-base-engine-3.14.1.jar:3.14.1]
> > > ....
> > > Caused by: java.lang.IllegalStateException: Queue full
> > > at java.util.AbstractQueue.add(AbstractQueue.java:98) ~[na:1.8.0_312]
> > > at
> > > org.apache.camel.component.seda.SedaProducer.addToQueue(SedaProducer.java:251)
> > > ~[camel-seda-3.14.1.jar:3.14.1]
> > > at
> > > org.apache.camel.component.seda.SedaProducer.process(SedaProducer.java:149)
> > > ~[camel-seda-3.14.1.jar:3.14.1]
> >
> >
> >
> > Thanks,
> > --
> > -------------------------------------------
> > Craig Taylor
> > ctalk...@ctalkobt.net
>
>
>
> --
> Claus Ibsen
> -----------------
> http://davsclaus.com @davsclaus
> Camel in Action 2: https://www.manning.com/ibsen2
--
Claus Ibsen
-----------------
http://davsclaus.com @davsclaus
Camel in Action 2: https://www.manning.com/ibsen2
