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. How to release this
connection once subscription is over? Is it an issue with Camel?
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>()
{
// 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 - Users mailing list archive at Nabble.com.
