I am using Camel 2.9.1 and Java DSL.
I attempted to setup an expiration time for my custom message being sent to
a queue such as:
.from()
// DO some processing and create message
.setHeader("JMSExpiration", constant(System.currentTimeMillis() + 3000))
.setHeader("JMSDeliveryMode
I have an Apache Camel Splitter such as the following:
...
from("{{direct.split}}")
.split().method(splitter, "iterate").streaming()
.stopOnException()
.setHeader("{{header.index}}", simple("${property.CamelSplitIndex}++"))
// Other processing
.choice
.when(property(Ex
It doesn't appear that Exchange.SPLIT_COMPLETE, Exchange.SPLIT_SIZE,
etc...are available outside the .splitter block. My original thought was to
use those provided properties.
I can try the always return 1 approach.
--
View this message in context:
http://camel.465427.n5.nabble.com/How-can-I-t
So I ended up using a class variable which is initially set to 0. If there
are elements to parse then when the splitter is complete it will update the
class variable through the use of a processor. Then after the splitter logic
I call another processor to get the number of elements parsed. If still
I have read several posts on suspending routes such as
http://camel.465427.n5.nabble.com/Suspend-route-what-about-the-current-exchange-td5545837.html
and have read
https://camel.apache.org/how-can-i-stop-a-route-from-a-route.html.
The problem I am having is that in the time that it takes to spawn
