Thursday, 5 September 2013

How can I improve the performance of a Seda queue?

How can I improve the performance of a Seda queue?

Take this example:
from("seda:data").log("data added to queue")
.setHeader("CamelHttpMethod", constant("POST"))
.setHeader(Exchange.CONTENT_TYPE,
constant("application/json"))
.process(new Processor() {
public void process(Exchange exchange) throws
Exception {
exchange.setProperty(Exchange.CHARSET_NAME,
"UTF-8");
}
})
.recipientList(header(RECIPIENT_LIST))
.ignoreInvalidEndpoints().parallelProcessing();
Assume the RECIPENT_LIST header contains only one http endpoint. For a
given http endpoint, messages should be processed in order, but two
messages for different end points can be processed in parallel.
Basically, I want to know if there is anything be done to improve
performance. For example, would using concurrentConsumers help?

No comments:

Post a Comment