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
unit-tests/src/test/java/org/apache/activemq/demo/SimpleQueueSender.java
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Non-blocking-interceptor-for-MQTT-tp4715995p4716281.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
3:29:19 AM
Subject: Non blocking interceptor for MQTT
Is there a way to have a non-blocking interceptor for MQTT in Artemis?
I am working on a project and basically I intercept incoming MQTT packets
and perform some computations. But this effects the throughput at the
subscriber end as the comput
Is there a way to have a non-blocking interceptor for MQTT in Artemis?
I am working on a project and basically I intercept incoming MQTT packets
and perform some computations. But this effects the throughput at the
subscriber end as the computations are slightly heavy. Is there a way to
have the
