osdir.com

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Re: Intercept mqtt client connection


What you want to do is possible using an interceptor like you've
implemented.  The broker even ships with a working example demonstrating a
working MQTT interceptor.  It's called "interceptor-client-mqtt".

Your interceptor code looks fine.  Did you add it to your broker.xml?


Justin

On Thu, Dec 14, 2017 at 1:44 AM, Gupta Bharat <bharat.gupta@xxxxxxxxxx>
wrote:

> Hello,
>
> I want to intercept clients when trying to connect in order to do some
> checks before allowing them to connect.
> How could I add needed features to Artemis broker interceptor? Is this
> possible in ActiveMQ?
>
> I have written following code which is not working on connecting the
> activemq broker with MQTT client.
>
> import org.apache.activemq.artemis.api.core.ActiveMQException;
> import org.apache.activemq.artemis.core.protocol.mqtt.MQTTInterceptor;
> import org.apache.activemq.artemis.spi.core.protocol.RemotingConnection;
> import org.apache.log4j.Logger;
>
> import io.netty.handler.codec.mqtt.MqttConnectMessage;
> import io.netty.handler.codec.mqtt.MqttMessage;
>
> public class MyInterceptors implements MQTTInterceptor {
>
>       final static Logger logger = Logger.getLogger(MyBroker.class);
>
>       @Override
>       public boolean intercept(MqttMessage arg0, RemotingConnection arg1)
> throws ActiveMQException {
>
>             logger.info("MQTT Interceptor gets
> called--------------------------------------------------------------");
>
>
>           if (arg0 instanceof MqttConnectMessage)
>           {
>                   logger.info("MQTT Interceptor gets
> called--------------------------------------------------------------");
>           }
>           return true;
>
>       }
>
> }
>
>
>
> Regards,
> Bharat Gupta
> Development & Support | Platform Technician, IXCB | Scania IT
> Mobile: +46700869007, +91-9718483802
> bharat.gupta@xxxxxxxxxx<mailto:bharat.gupta@xxxxxxxxxx>
>
>