Huge amount of ActiveMQ threads which leads application slowness

Hi, there The application is running in Servcemix contains as a SA. The application has two components : DataCollector and DataConverter. DataCollector uses fileAlternativeMonitor to monitor directory and copy file to DataConverter. DataConverter parse raw file, mostly it is CSV file. The appl

Huge amount ActiveMQ threads leads application slowness

Hi, The application is running in Servcemix contains as a SA. The application has two components : DataCollector and DataConverter. DataCollector uses fileAlternativeMonitor to monitor directory and copy file to DataConverter. DataConverter parse raw file, mostly it is CSV file. The application

Re: Interceptor for MQTT

It's not working because that feature is not implemented in the broker as I stated in a previous email. There's no way to get it working unless you modify the broker to support it. Justin - Original Message - From: "vicky" To: users@activemq.apache.org Sent: Wednesday, June 29, 2016

Re: Interceptor for MQTT

Hi, I am facing the same issue. The interceptor is not working for MQTT messages. The pub/sub is working though. Please help me if you were able to get it working. Thanks, Vicky

Re: Interceptor for MQTT

The MQTT broker implementation does not currently support interceptors. Contributions are welcome, of course. You can look at how the Core and Stomp protocol implementations handle this for guidance if you wish. Justin - Original Message - From: "vpeng23" To: users@activemq.apache.org

Re: Interceptor for MQTT

Hello, I think you must send this request to d...@activemq.apache.org Le 28 juin 2016 02:38, "Vincent Peng" a écrit : > Hi, > > I'm wondering if the interceptor can support MQTT protocol. > I tested the example > in activemq-artemis/examples/features/standard/interceptor and the > interceptor ca

Re: Interceptor for MQTT

I found the following codes in artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTProtocolManagerFactory.java @Override public List filterInterceptors(List list) { // TODO Add support for interceptors. ActiveMQServerLogger

Re: Artemis as MQTT broker

On 30 Jun 2016 05:26, "Ragavan Thiru" wrote: > > Thanks for the information Martyn. > > What I meant by third question is, will internally Artemis uses JMS when it > is configured as MQTT broker? No. Is it possible to make Artemis do the direct > translation from MQTT message to core messages? Ye