Polling consumer poll period

Hi, Although timer period is 10 seconds , when i check the logs I can see this polling occurs every 1 minute. I changed the polling consumer timeout but same result. Why is this behaviour ? Note : Using camel 2.18.0 with Spring Boot. from("timer://mytimer?period=1")

Re: Conditional Polling Consumer

Try enrich() http://camel.apache.org/content-enricher.html > On Nov 1, 2016, at 1:30 PM, Kasim Sert wrote: > > I have an apache camel application which runs as three identical services > in production environment for

Conditional Polling Consumer

I have an apache camel application which runs as three identical services in production environment for scalability. I want to add email server polling to this application using camel-mail api. Since I dont want all these three instances poll the server concurrently, I want to put some locking

subscribe camel-users

Re: Java DSL: How to inject object endpoint?

I'll look into this, thanks. Regards, Allan C. On Tue, Nov 1, 2016 at 10:21 PM, Brad Johnson wrote: > You may also want to look at @EndpointInject with uri of the route you want > to invoke. That depends on the specific needs. You might use that in the > case

RE: zipfile question - thank you

DefaultErrorHandler | 198 - org.apache.camel.camel-core - 2.15.1.redhat-620133 | Failed delivery for (MessageId: ID-alphprdfuse2i-43262-1478008924653-2-36907 on ExchangeId: ID-alphprdfuse2i-43262-1478008924653-2-36908). Exhausted after delivery attempt: 1 caught:

Re: Question on multicast to pipelines

Edoardo, I missed the second set of logging statements, sorry. I thought you'd said they were outputting the same thing. And, yes, that's a bit counter-intuitive. Personally I almost always do it with just to routes in the mulitcast and then any further routing or changes I put in those. And I

Re: Question on multicast to pipelines

Ah, I didn't understand what you were saying before. Your point is that these two should be synonymous, even if they're enclosed in a multicast()...end(): 1) This... .*pipeline("direct:A", "direct:B")* 2) and this... .*pipeline().to("direct:C").to("direct:D").end()* but only the

RE: Zip all files available in folder - synchronously

Thanks Clause for the reply. So I assume there is no default approach via Camel Aggregator. What I have done currently is used Looping with reading from File Endpoint with maxPollMessage = 1. As we are using 2.16 version, the only way this loop based solution works if we know before-hand how

Re: Question on multicast to pipelines

I don’t see how .pipeline().to(“A”).to(“B”).end() should not be equivalent to .pipeline(“A”, “B”), or to .to(“A”, “B”) which is - for what I understood from documentation - equivalent to the pipeline statement anyway. I am of course changing data in the A and C steps, please go look at the gist

QuartzScheduledPollConsumerScheduler, cluster and scheduler.triggerId

Am using a camel file consumer within a cluster to poll files on a periodic basis. I wish to ensure that a consumer will only poll files if it has an exclusive read lock on them so using the QuartzScheduledPollConsumerScheduler with a readLock=idempotent read lock strategy backed by a

Re: Hystrix Fallback not executed on Thread Pool/Semaphore rejection

Great, thank you for the fix. On Tue, Nov 1, 2016 at 7:23 AM, Claus Ibsen wrote: > Hi > > Ah yes thats a bug. I have logged a ticket > https://issues.apache.org/jira/browse/CAMEL-10430 > > We should get the exception from the command which then also has > exception for

Re: Java DSL: How to inject object endpoint?

You may also want to look at @EndpointInject with uri of the route you want to invoke. That depends on the specific needs. You might use that in the case where you want to iterate over items in a list, mutate some data or filter items and find it easier to do in a Java POJO than in the route

Re: Question on multicast to pipelines

That's what you should see unless you change the data in A or in C. A and C should both receive START. It is a multicast. If you change the value in A you'll see that change in B but that will not be shown in C since C is at the root of the multicast. If you change the data in C you'll see it in

Re: Camel-REST vs Cxfrs

Claus Ibsen-2 wrote > Camel in Action 2nd ed book has a full chapter on REST and various ways to > use it with Camel. Yes, looking at the MEAP edition got me wondering if that was the general direction: i.e. to encourage the use of the REST DSL unless there were specific reasons for one of the

camel 2.18.0 blueprint message metrics fail

In Camel 2.18.0 under Karaf, using blueprint, now messageMetrics fail indicating messageMetrics must be specified. This is different behavior from Camel 2.17.3, where no such component configuration was required. Any ideas how to fix them? -- View this message in context:

Re: Camel Hystrix behaviour when circuit is open

Hi Ah sorry didn't spot this email. Only now when I searched for hystrix in our user forum. We got this reported recently again. I logged a ticket and fixed it: https://issues.apache.org/jira/browse/CAMEL-10430 On Tue, Oct 25, 2016 at 3:59 PM, jamesnetherton wrote: >

Re: Hystrix Fallback not executed on Thread Pool/Semaphore rejection

Hi Ah yes thats a bug. I have logged a ticket https://issues.apache.org/jira/browse/CAMEL-10430 We should get the exception from the command which then also has exception for other kind of failures such as rejected etc On Mon, Oct 31, 2016 at 3:44 PM, Maxime Tremblay

Re: Camel-REST vs Cxfrs

Claus, On 01/11/16 10:48, Claus Ibsen wrote: There are some JIRA tickets to integrate camel-cxf with rest-dsl. However this requires some changes in CXF to facilitate this. It is not quite correct. As I pointed out at the time, while attaching the initial patches to the relevant Camel issues,

R: Re: camel 2.18.0 rabbitmq component fails under Karaf

Non sure. Need to investigate a bit Il mar, 1 nov, 2016 alle 11:59, souciance ha scritto: Does anyone know why you need to do that?  It isn't necessary in 2.17.0 and karaf 4.0.2. Den 31 okt. 2016 2:09 em skrev "gustavo.maurizio [via Camel]" <

Re: camel 2.18.0 rabbitmq component fails under Karaf

Does anyone know why you need to do that? It isn't necessary in 2.17.0 and karaf 4.0.2. Den 31 okt. 2016 2:09 em skrev "gustavo.maurizio [via Camel]" < ml-node+s465427n5789514...@n5.nabble.com>: > Andrea, fantastic! > Adding this install -s wrap:mvn:junit/junit/4.12 before installing made > it

Re: JpaConsumer endpoint not showing up in hawtio.

Ok i'll try with a newer version, anyway could you explain or show an example of how do you use that component? Thanks -- View this message in context: http://camel.465427.n5.nabble.com/JpaConsumer-endpoint-not-showing-up-in-hawtio-tp5789346p5789554.html Sent from the Camel - Users mailing

Re: Camel-REST vs Cxfrs

Oh also camel-cxf with cxfrs is a bit to bloated with both WS and RS mixed together. There is also a JIRA ticket to separate this and make the dependencies smaller and leaner. On Tue, Nov 1, 2016 at 11:48 AM, Claus Ibsen wrote: > There are some JIRA tickets to integrate

camel-quartz failed camel route creation when database is unreachable

Hi Everyone: My bundle osgi installed into karaf container 4.0.7, that use camel-quartz2-2.17.3 In camelContext I have many routes such as "myRoute", it call a job quatrz (using camel-quartz2) configured in postgresql database:

Re: Camel-REST vs Cxfrs

There are some JIRA tickets to integrate camel-cxf with rest-dsl. However this requires some changes in CXF to facilitate this. Some of the CXF committers from Talend said they would like to work on that, but they don't seem to had the time yet to work on this. That said you can always code REST

Re: camel 2.18.0 rabbitmq component fails under Karaf

Hi Andrea do we have an issue in 2.18.x branch with installing camel-rabbitmq? Then we may need to get this fixed? Also its a bit weird that junit is needed to be installed, that is for testing ;) On Mon, Oct 31, 2016 at 2:09 PM, gustavo.maurizio wrote: > Andrea, fantastic! >

Re: JpaConsumer endpoint not showing up in hawtio.

Yeah you can do that, but its not very often in use. Try with a newer Camel release. 2.16.x is EOL. On Mon, Oct 31, 2016 at 5:27 PM, raulsperoni wrote: > I'm doing exactly that...creating the instance like you say. > > Sorry the ignorance, how am i supposed to do it? > > > >

Re: Zip all files available in folder - synchronously

You cannot do this the aggregate is in 2 different threads. Don't use the direct endpoint but do something different to trigger the route to start and aggreage those files, and then get an event when its done, which you can then use to know when the zip is ready. On Mon, Oct 31, 2016 at

Re: Camel-REST vs Cxfrs

On 01/11/16 07:42, souciance wrote: I guess it strictly depends on your requirements. If the REST DSL satisfy your requirements and a POC shows it works for you it probably makes sense to use it. I am not sure if there is such a condition as to always use one above the other, unless off course

Re: camel 2.18.0 VM problem after update

Hi Maybe this bug fixes this https://issues.apache.org/jira/browse/CAMEL-10406 You can build latest code and test with a SNAPSHOT version http://camel.apache.org/building On Mon, Oct 31, 2016 at 3:14 PM, Marvin wrote: > I updated my camel version from 2.15.2 to 2.18.0.

Re: Question on multicast to pipelines

Hi all, these are the results I get, only the most explicit and verbose configuration returns the expected result. Working route: .pipeline().to("A").to("B").end() .pipeline().to("C").to("D").end() 10:41:12.644 [main] INFO route1 - after direct:start body=START 10:41:12.666 [main] DEBUG

Re: Camel-REST vs Cxfrs

I guess it strictly depends on your requirements. If the REST DSL satisfy your requirements and a POC shows it works for you it probably makes sense to use it. I am not sure if there is such a condition as to always use one above the other, unless off course the camel-cxfrs will be discontinued,

RE: Zip all files available in folder - synchronously

HI JB, Can you elaborate a little. At least the code I have written below, I always see Aggregation happening in separate thread and not main-thread. And which method you mean by stopping condition? Tried completionFromBatchConsumer and completionSize, without any luck. Regards, Arpit.

Re: Zip all files available in folder - synchronously

Hi Arpit, The aggregate should work for that. All depends on the "stopping condition". Regards JB On 10/31/2016 11:04 PM, Goyal, Arpit wrote: Hi Colleagues, I want to read all file and aggregate into one single zip, but the batch consumer always run in different thread. What needs to be