I tried hosting the same ActiveMQTransport code inside a worker service, everything works like a charm. Now trying to simulate an outage in ActiveMQ instance as follows.
1- Run the consumer.
2- Turn off the ActiveMQ instance.
3- Turn it back on.
4- Run the producer to send 1000 message.
5- The consumer is not reconnecting to ActiveMQ.
Is there a way to handle that from within the library?