reactive java question

2020-05-26 Thread Bing Lu
I have to incorporate a third party api in order to use the reactive functionality of the api. I'm using spring boot with this third party jar, and the starting point is the onNext() method that get invoked whenever an event occurs. My question is how do I make the onNext() method as a starting

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 api

RE: reactive java question

2020-05-27 Thread Micael Kirouac
rect api' more specifically. -Original Message- From: Mark Nuttall [mailto:mknutt...@gmail.com] Sent: Wednesday, May 27, 2020 7:48 PM To: users@camel.apache.org Subject: Re: reactive java question Without seeing the actual code I can't say for sure but I would use producer template d

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 s

Re: reactive java question

2020-05-30 Thread Bing Lu
I figured it out, I can just use @produce and pump the result of the bean method to the endpoint, and once the bean method(onNext) is invoked, it will start flowing in camel. Silly me. On Wednesday, May 27, 2020, 08:00:41 PM EDT, Bing Lu wrote: Our code is subscriber only that consum