Re: Non blocking interceptor for MQTT

2016 6:33:12 PM Subject: Re: Non blocking interceptor for MQTT Hi, I tried your suggestion. It works. I run a separate thread which continuously removes messages from the queue and does the processing. However, the problem is I get the below exception when I close the broker. javax.jms.JMSExcep

Re: Non blocking interceptor for MQTT

Hi, I tried your suggestion. It works. I run a separate thread which continuously removes messages from the queue and does the processing. However, the problem is I get the below exception when I close the broker. javax.jms.JMSException: AMQ119016: Connection failure detected. Unblocking a bloc

Re: Non blocking interceptor for MQTT

You already have a simple way to achieve what you want built in to the broker itself. Simply send a non-blocking message from the interceptor which contains the data you need to perform the computation to a queue and then have a separate client which consumes those messages and performs the com