[CAMEL-9894] RXCamel is not releasing the ActiveMQ connection once the subscription is complete

• Type: Bug
• Status: Resolved
• Priority: Critical
• Resolution: Invalid
• Affects Version/s: 2.17.0
• Component/s: camel-rx
• Estimated Complexity: Unknown
• Assignee: Claus Ibsen
• Reporter: Arun
• Created: 20/Apr/16 15:02
• Updated: 22/Apr/16 10:40
• Resolved: 21/Apr/16 15:12

Description

I am using camel-rx to observe some messages from Active MQ. After I complete the subscription I am getting onCompleted() event also. But If I look in Active MQ console, I can still see the consumer live.
I feel Is it an issue with camel. How to release this connection once subscription is over?

Code :

ReactiveCamel rx = new ReactiveCamel(camel);

Observable<Message> observable1 = rx.toObservable("activemq:queue:Output Queue - 01?selector=JMSCorrelationID%3D'"+ uuid + "' AND eventType%3D'cust_msg'");

observable1.first().subscribe(new Subscriber<Message>() {

// methods here

}

Issue Links

• Blocked: CAMEL-9899 camel-rx - Use a worker pool for tasks such as stopping consumers