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
ActiveMQ] <
> > > > [hidden email] > /user/SendEmail.jtp?type=node&node=4713576&i=1>>
> > > wrote:
> > > >
> > > > > It's not working because that feature is not implemented in the
> > broker
> > > as
>
t; 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.
> > &
27;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" <[hidden email]
> > > <http:///user/SendEmail.jtp?type=node&node=4713526&i=0>>
> > > To: [hidden email] /user/SendEmail.jt
revious email. There's no way to get it working unless
you
> > modify the broker to support it.
> >
> >
> > Justin
> >
> > - Original Message -
> > From: "vicky" <[hidden email]
> > <http:///user/SendEmail.jtp?type
ype=node&node=4713526&i=0>>
> To: [hidden email] <http:///user/SendEmail.jtp?type=node&node=4713526&i=1>
> Sent: Wednesday, June 29, 2016 8:39:29 AM
> Subject: Re: Interceptor for MQTT
>
> Hi,
>
> I am facing the same issue.
> The interceptor is n
Hi,
Is there any other way to get the messages that has been published to the
MQTT broker? Please help.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Interceptor-for-MQTT-tp4713408p4713523.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
On Fri, Jul 1, 2016 at 2:40 AM, Justin Bertram wrote:
> 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.
>
I've submitted a Feature Request for it
https://issu
esday, June 29, 2016 8:39:29 AM
Subject: 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
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
To: users@activemq.apache.org
Sent: Thursday, June 30, 2016 11:31:55 AM
Subject: 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
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
.
ActiveMQServerLogger.LOGGER.warn("MQTT!! Add support for
interceptors!!");
return null;
}
Does this mean the MQTT protocol in Artemis can't support interceptor?
- Vincent
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Interceptor-for-MQTT-tp4713408p4713493.htm
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 can work with the provided example. However, when I use MQTT
protocol to publish/subscribe, the interceptor seems not working. (The MQ
18 matches
Mail list logo
