How to read messages from a queue in parallel

2018-12-17 Thread Peter Billen
Hi all, I am reading from a RabbitMQ queue as following: from("rabbitmq://localhost/?queue=camel&autoAck=false&concurrentConsumers=1& threadPoolSize=1&prefetchEnabled=true&prefetchCount=50") Some remarks about the configuration parameters: - I set `autoAck` to false to be able to acknowledge ma

How to use the camel-ssh feature to help me manage remote services such as the nginx reload command

2018-12-17 Thread 一剑飘红
I have a need First I sync the file to the web server via camel-sftp After transferring the file, do the nginx -s reload command on each server. My code is as follows But why pollcomand doesn't work from("file:I:/workProject/java//luaFiles/").multicast().to("direct:a", "direct:b").end().to

How to use the camel-ssh feature to help me manage remote services such as the nginx reload command

2018-12-17 Thread ??????
I have a need First I sync the file to the web server via camel-sftp After transferring the file, do the nginx -s reload command on each server. My code is as follows But why pollcomand doesn't work from("file:I:/workProject/java//luaFiles/").multicast().to("direct:a", "direct:b").en

Re: How to use the camel-ssh feature to help me manage remote services such as the nginx reload command

2018-12-17 Thread Andrea Cosentino
The pollCommand can be used only on a consumerEndpoint. So you should have from("ssh://root@192...?pollCommand=reboot%0A") Also it's pollCommand and not poll-command -- Andrea Cosentino  -- Apache Camel PMC Chair Apache Karaf Committer Apache Servicemix PMC Member

RE: How to read messages from a queue in parallel

2018-12-17 Thread Valdis Andersons
Hi Peter, Given you have a header already identifying the message categories, you could try to look into the Aggregator EIP: http://camel.apache.org/aggregator2.html It will allow you to group all the messages by the header into 'batches' for each of the groups. Each batch can then be processe

Camel + Spring DSL + LRA SagaService

2018-12-17 Thread Sanjeev Kumar
Hi, Thanks for guiding me how to add InMemorySaga service. It worked like Charm!! Now, I am trying to work with LRA Service and as mentioned at https://github.com/apache/camel/blob/master/camel-core/src/main/docs/eips/saga-eip.adoc, I added LRA and Undertow dependencies. But, when I am starting t