Group Commands for parallel processing (dynamic routes)

2022-09-07 Thread Mansour Al Akeel
I have a stream of commands that needs to be processed in parallel for performance reasons, and to be grouped on a key for sequential processing to avoid conflicts. I don't know the number of groups in advance. One way that came to my mind, is dynamic channels/queues. So the stream of commands is

Re: Types in routeTemplates

2022-09-07 Thread Claus Ibsen
Hi Yes, it's intended to have string types that accept property placeholders. But sometimes you need to add them manually. A long term goal is to generate all DSLs from a canonical DSL meta-model, then we can ensure a consistent way for all programming languages, eg Java, Kotlin, Groovy etc. But

InOut-exchange over sjms fails if remote uses streamcaching and spools to disk

2022-09-07 Thread Simo Hakanen
Hello list We use camel to route messages over sjms (activemq) between processes, where the remote end runs a route that does some processing and returns a large json-response. After experimenting with streamcaching on that remote end, we noticed that if the stream is spooled to disk, the route fa

Re: Types in routeTemplates

2022-09-07 Thread ski n
That's nice. I already found out you can write for example the throttle as: .throttle(1).timePeriodMillis(1000) Thus with two longs as input, but it's also possible: .throttle(constant("{{maximumrequestcount}}")).timePeriodMillis("{{timeperiod}}") In the second case the first parameter is an e