Re: Environment variable not accessible if camel run in Cron Job of CentOS

2019-11-13 Thread Claus Ibsen
Hi Hmm I wonder if its something with permission issue, eg run cron vs normal. Camel uses the JDK api to get env variables from System.getenv, so you can try some java code that does that and see if you can get those from the cron job or not. On Wed, Nov 13, 2019 at 8:54 PM Imran Raza Khan

Re: How to get route Exception in a processor with camel+rabbitmq

2019-11-13 Thread Alessandro Hoss
Hi .. "myExchange" is not the queue name... When working with rabbitmq, you always send the message to a "RabbitMQ Exchange", which redirects it to some queue based on the routingKey (which is defined on the creation of the queue)... quite complex, but RabbitMQ component has different concepts

Re: How to aggregate files after producer created all files?

2019-11-13 Thread Mantas Gridinas
I suppose the solution would not be using the file component at all, but rather agregating messages and using ZipOutputStream to convert those messages into a zip file and only then to store it in the file system via file component. On Wed, Nov 13, 2019, 20:57 WEIQUAN YUAN wrote: > can you use

Environment variable not accessible if camel run in Cron Job of CentOS

2019-11-13 Thread Imran Raza Khan
I have one jar file which contain camel route to run it from cron job i created shell script public void process(Exchange exchange) throws Exception { String host = exchange.getContext().resolvePropertyPlaceholders("{{env:HOSTNAME}}"); } test.sh #!/bin/sh java -jar my.jar Now when i

Re: How to aggregate files after producer created all files?

2019-11-13 Thread WEIQUAN YUAN
can you use some indicator to check if all the files are created or not. If it is not true, you don't need to call another route in choice when condition. On Wed, Nov 13, 2019 at 8:45 AM Mikael Andersson Wigander < mikael.grevs...@gmail.com> wrote: > Hi > > I have a route that creates up to ten

Re: How to get route Exception in a processor with camel+rabbitmq

2019-11-13 Thread WEIQUAN YUAN
why your from queue name is same as to queue name? On Wed, Nov 13, 2019 at 9:10 AM Alessandro Hoss wrote: > Hello guys, > > I've a route with onException, which sends the message to rabbitMQ, and > another route listening rabbit to call a processor and get the exception > thrown. I'm able to

Re: restart stopped route automatically due to exception

2019-11-13 Thread Bing Lu
should i use cachingconnectionfactory instead of just mqconnectionfactory in sjms component? i am using 2.23.1   exception below Exception caught closing session: JMSCMQ0002: The method 'MQBACK' failed.. This exception is ignored.

Re: Stopping a JMSConsumer started in a RecipientList

2019-11-13 Thread Tim Mullender
Brilliant, setting the cache size on the recipient list to -1 seems to do the job. Thank you very much Tim > On 13 Nov 2019, at 15:16, Claus Ibsen wrote: > > Hi > > You can set the cache size of the recipient list to 0 or so to turn it > off, then camel ought to stop the jms endpoint et

Re: restart stopped route automatically due to exception

2019-11-13 Thread Claus Ibsen
Hi What Camel version are you using? And can you maybe show some code snippet of that route that was stopped. And maybe something from the logs that points to how it was stopped. Also if you are using JMS then have you setup your connection pool with re-connection logic et all. On Wed, Nov 13,

Re: Stopping a JMSConsumer started in a RecipientList

2019-11-13 Thread Claus Ibsen
Hi You can set the cache size of the recipient list to 0 or so to turn it off, then camel ought to stop the jms endpoint et all after its done using it. On Wed, Nov 13, 2019 at 3:35 PM Tim Mullender wrote: > > Thanks Claus, unfortunately I don’t have an option to change the broker so > I’m not

restart stopped route automatically due to exception

2019-11-13 Thread Bing Lu
hi, is there a way to automatically restart a route that got stopped due to some exception caused by server patching, queue unavailable for a short period of time? I am using sjmsbatch and one of the route is stopped and never restarted during the maintenance window because it caught an

Re: Stopping a JMSConsumer started in a RecipientList

2019-11-13 Thread Tim Mullender
Thanks Claus, unfortunately I don’t have an option to change the broker so I’m not able to use ActiveMQ >From browsing the MBeans in JConsole and a quick look at the source code I >don’t see that the JmsProducer or QueueReplyManager are available through >JMX. I can access the routes,

How to get route Exception in a processor with camel+rabbitmq

2019-11-13 Thread Alessandro Hoss
Hello guys, I've a route with onException, which sends the message to rabbitMQ, and another route listening rabbit to call a processor and get the exception thrown. I'm able to reach this processor, but i'm not able to get the exception thrown. I've tried with the property set to false, and

How to aggregate files after producer created all files?

2019-11-13 Thread Mikael Andersson Wigander
Hi I have a route that creates up to ten different files in a directory and another route that zips all these files. We see in some scenarios that the zipping is done BEFORE all files have been created. Ending up with two zip files, one with eight files and one with two files. The zip-route