Re: RXCamel is not releasing the ActiveMQ connection once the subscription is complete

I have used WMQ with JMSComponent and JMSConsumer threads are live after onComplete and unsubscribe. Can you please help on this? -- View this message in context: http://camel.465427.n5.nabble.com/Camel-rx-is-not-releasing-the-ActiveMQ-connection-once-the-subscription-is-complete-tp5781482p578

Re: RXCamel is not releasing the ActiveMQ connection once the subscription is complete

I have used WMQ with JMSComponent and JMSConsumer threads are still live after onComplete() and unsubscribe(). Can you please help on this? If the way I am setting RxCamel on the queue is not correct, please suggest the right approach. I was following the example on RxCamel page. -- View thi

Re: RXCamel is not releasing the ActiveMQ connection once the subscription is complete

I tried using active MQ and WMQ. Both the cases the threads created by RX remains. Can you please suggest how I can release or avoid this? -- View this message in context: http://camel.465427.n5.nabble.com/Camel-rx-is-not-releasing-the-ActiveMQ-connection-once-the-subscription-is-complete-tp57

Re: RXCamel is not releasing the ActiveMQ connection once the subscription is complete

The below code is creating the Active MQ threads. Is there a way I can avoid the creation of these threads? Or close those threads on completion of the subscription. Due to this I am stuck. Please suggest a solution ReactiveCamel rx = new ReactiveCamel(camel); Observable observable1 = rx.toObserv

Re: RXCamel is not releasing the ActiveMQ connection once the subscription is complete

Can you please look into this? -- View this message in context: http://camel.465427.n5.nabble.com/Camel-rx-is-not-releasing-the-ActiveMQ-connection-once-the-subscription-is-complete-tp5781482p5782111.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: RXCamel is not releasing the ActiveMQ connection once the subscription is complete

I am using camel-rx to connect to a queue from a web application. Each time I invoke the REST service it will publish a message and observe the queue with reactive camel. once it gets back a message from queue based on the correlation id, it will return the response back to the user. But a new act

Re: RXCamel is not releasing the ActiveMQ connection once the subscription is complete

Those are ActiveMQ threads as you embed an entire ActiveMQ broker then it has its own set of threads it runs. On Thu, Apr 28, 2016 at 11:12 AM, arunkabraham wrote: > Can you please suggest on the issue mentioned above? > > > > -- > View this message in context: > http://camel.465427.n5.nabble.co

Re: RXCamel is not releasing the ActiveMQ connection once the subscription is complete

Can you please suggest on the issue mentioned above? -- View this message in context: http://camel.465427.n5.nabble.com/Camel-rx-is-not-releasing-the-ActiveMQ-connection-once-the-subscription-is-complete-tp5781482p5781857.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: RXCamel is not releasing the ActiveMQ connection once the subscription is complete

Hi I have built camel and tested. The consumers are getting released. I am using it in a spring boot application. But after 5 requests Still I can see lot of threads getting created and not released. But in active MQ console no pending consumers. Please find below the screen shots 1) After Ser

Re: RXCamel is not releasing the ActiveMQ connection once the subscription is complete

You need to build camel-core as 2.17.1 SNAPSHOT also. You can look at the release history of Camel to have an idea when new releases are coming out. But I would expect 2.17.1 released in next month. On Mon, Apr 25, 2016 at 10:17 AM, arunkabraham wrote: > I built the camel-rx module and used the

Re: RXCamel is not releasing the ActiveMQ connection once the subscription is complete

I built the camel-rx module and used the latest jar in my code. Now I am getting an error Exception in thread "main" java.lang.NoSuchMethodError: org.apache.camel.CamelContext.addService(Ljava/lang/Object;ZZ)V at org.apache.camel.rx.support.EndpointSubscription.(EndpointSubscription.java:

Re: RXCamel is not releasing the ActiveMQ connection once the subscription is complete

Ok thanks. When will be the new version available (2.7.1)? -- View this message in context: http://camel.465427.n5.nabble.com/Camel-rx-is-not-releasing-the-ActiveMQ-connection-once-the-subscription-is-complete-tp5781482p5781543.html Sent from the Camel - Users mailing list archive at Nabble.com

Re: RXCamel is not releasing the ActiveMQ connection once the subscription is complete

On Thu, Apr 21, 2016 at 11:16 PM, arunkabraham wrote: > I didnt understand properly. Was I doing some mistake? You attempt to stop the JMS consumer from the same thread that consumed the message, eg spring-jms do not support this, and goes into an endless loop. You need to use a separate thread

Re: RXCamel is not releasing the ActiveMQ connection once the subscription is complete

I didnt understand properly. Was I doing some mistake? With the new version it will be resolved? -- View this message in context: http://camel.465427.n5.nabble.com/Camel-rx-is-not-releasing-the-ActiveMQ-connection-once-the-subscription-is-complete-tp5781482p5781512.html Sent from the Camel - Us

Re: RXCamel is not releasing the ActiveMQ connection once the subscription is complete

Hi Okay fixed by https://issues.apache.org/jira/browse/CAMEL-9899 Its because you stop the jms consumer from the event thread which is the thread that consumed the message. The ticket resolves this by stopping using a thread pool for those tasks so they dont steal the thread from RX. On Thu, A

Re: RXCamel is not releasing the ActiveMQ connection once the subscription is complete

I have created a sample project and uploaded the zip to the github location https://github.com/arunkabraham/Camel-RX Its just a main program which sends a messages to activemq and fetch it from there using camel-RX. But the connection to the active-mq i

Re: RXCamel is not releasing the ActiveMQ connection once the subscription is complete

observable1.first().subscribe(new Subscriber() > { > // implementing methods here > } > > > > -- > View this message in context: > http://camel.465427.n5.nabble.com/RXCamel-is-not-releasing-the-ActiveMQ-connection-once-the-subscription-is-complete-tp5781482.html > Sent from the Camel

RXCamel is not releasing the ActiveMQ connection once the subscription is complete

menting methods here } -- View this message in context: http://camel.465427.n5.nabble.com/RXCamel-is-not-releasing-the-ActiveMQ-connection-once-the-subscription-is-complete-tp5781482.html Sent from the Camel - Users mailing list archive at Nabble.com.