Hi
Thanks for all the input.
Decided to use Jan's excellent suggestion, and non-IDE tested code
that worked straight off! :)
Many thanks indeed,
I'm slowly learning how powerful Camel is!
Cheers
On Mon, 24 Feb 2020 at 23:02, Jan Bednář <m...@janbednar.eu> wrote:
>
> Hi,
> another idea can be pollEnrich. Content Enricher produces empty message,
> when timeout occures (in this case 1s). You can react on this by
> stopping route.
>
> from("timer:drain_messages?period=1")
> .pollEnrich("jms:queue?selector=whatever", 1000)
> .choice()
> .when(body().isNull())
> .to("controlbus:route?routeId=current&action=stop&async=true")
> .otherwise()
> .to("log:do_actual_processing");
>
> I have wrote this directly to email without my IDE, but I think this
> should work.
>
> Dne 24.2.2020 v 14:32 nomit babraa napsal(a):
> > Hi
> >
> > Looks interesting but can't see a way to set that property from any
> > examples.
> >
> > I did find www reference to
> >
> > camel.springboot.duration-max-idle-seconds=
> >
> > but I was hoping for something I could set with JMS uri options or java DSL.
> >
> > Cheers
> >
> >
> >
> > On Mon, 24 Feb 2020 at 08:19, Alex Dettinger <aldettin...@gmail.com> wrote:
> >> Not sure about the exact implementation, but I would investigate the camel
> >> code around MainSupport.durationIdle.
> >>
> >> On Sun, Feb 23, 2020 at 11:22 PM nomit babraa <h.bab...@sheffield.ac.uk>
> >> wrote:
> >>
> >>> Hi
> >>>
> >>> I was wondering if there is any way to do the following:
> >>>
> >>> - A route starts up.
> >>> - It consumes certain messages from an AMQ queue using a selector.
> >>> - Once all current messages are consumed the route is
> >>> stopped/suspended (Control Bus, CamelContext.stop(),
> >>> THROTTLINGINFLIGHTROUTEPOLICY, etc)
> >>>
> >>> I think I can use schedulers and throttling to almost achieve what I
> >>> want but I explicitly want the route to be stopped when all current
> >>> messages that are found by the selector are consumed.
> >>>
> >>> I'm not sure how to get that metric and act upon it?
> >>>
> >>> Many thanks for any advice...
> >>>
> >>> n
> >>>
>
