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<Message> observable1 =
rx.toObservable("activemq:queue:OutputQueue01
?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/Camel-rx-is-not-releasing-the-ActiveMQ-connection-once-the-subscription-is-complete-tp5781482p5782246.html
Sent from the Camel - Users mailing list archive at Nabble.com.
