Re: reactive java question

2020-05-27 Thread Bing Lu
Our code is subscriber only that consumes event from onNext() which is the starting point of the flow. We're forced to use their api which implements the onNext() function On Wednesday, May 27, 2020, 07:48:08 PM EDT, Mark Nuttall wrote: Without seeing the actual code I can't say for

RE: reactive java question

2020-05-27 Thread Micael Kirouac
Did you take a look at camel reactive streams? https://camel.apache.org/components/latest/reactive-streams-component.html I never tried it personally but it should support what you need to do, see the sections 'sending data to camel' and 'sending data to camel using direct api' more

Re: reactive java question

2020-05-27 Thread Mark Nuttall
Without seeing the actual code I can't say for sure but I would use producer template do you send a message to a direct route and have that direct route to be in the from to start the processing in the route On Tue, May 26, 2020, 10:31 PM Bing Lu wrote: > I have to incorporate a third party

RE: errorHandler + onException

2020-05-27 Thread Shultz, Dmitry
Sorry, there is some typo te defaultEndpoint should be the top level route : template.setDefaultEndpointUri("direct:route1"); -Original Message- From: Shultz, Dmitry [mailto:dmitry_shu...@kaltire.com] Sent: Wednesday, May 27, 2020 3:04 PM To: users@camel.apache.org Subject: errorHandler

errorHandler + onException

2020-05-27 Thread Shultz, Dmitry
Hi All, What is the best way to handle the situation when there is a need to automatically adjust the exchange as part of the error handling and proceed with retry? For example, there is a route1 that invokes route2 with the 'token' property set. When, during the route2 execution there is

Re: Converting ProcessorDefinition to DSL and interfacing with camel k

2020-05-27 Thread Reji Mathews
Thanks for the right advice. It was just a curious question from the point of re-usability of what we have built so far. Yes, we are looking forward to doing it the way as suggested. Cheers Reji On Wed, May 27, 2020 at 12:59 AM Claus Ibsen wrote: > Hi > > No and that is not the purpose of

Re: Camel & NiFi

2020-05-27 Thread ski n
Thanks for the positive feedback. On the resilience topic. In NiFi the concept is based on data provenance and nodes. This functionality is built-in. As I wrote on my blog this is because NiFi follows very much a platform approach. Camel is as framework much more agnostic about where and how it

RE: Simple JMS Batch Component

2020-05-27 Thread Shenavai, Manuel
Hi, can someone comment on the below question? Thanks in advance & Best regards, Manuel From: Shenavai, Manuel Sent: Mittwoch, 20. Mai 2020 13:21 To: users@camel.apache.org Subject: Simple JMS Batch Component Hi everyone, I started looking into the Simple JMS Batching

RE: CamelCreatedTimestamp exchange property does not seem to be present anymore in camel 3.3.0

2020-05-27 Thread Ronny Aerts
Hello Claus, I saw the commits that solve my problem. Thank you for helping me out. -- Met vriendelijke groeten / Kind regards / Cordialement / Mit besten Grüßen, Ronny AERTS Product Owner Integrations / Integrations Manager e: ronny.ae...@wisetechglobal.com | t: +32 (0) 3 326 50 75

Re: Camel & NiFi

2020-05-27 Thread FabryProg
Thanks. I'll implements a mock example soon as possible. Have a good day! Fabrizio Il Mer 27 Mag 2020, 06:13 Jean-Baptiste Onofre ha scritto: > Hi, > > You can use ActiveMQ with persistent message between routes, it creates > kind of resilience. > It’s what I’m doing with most of my