Artemis courtier Intercept mqtt connexion client

Question

J'ai ajouté un intercepteur mqtt dans mon courtier artemis afin d'intercepter mqtt connexion client:

public class SimpleMQTTInterceptor implements MQTTInterceptor 
    { 

    @Override 
    public boolean intercept(final MqttMessage mqttMessage, RemotingConnection connection) throws ActiveMQException 
    { 

      System.out.println("MQTT Interceptor gets called "); 

      if (mqttMessage instanceof MqttConnectMessage) 
      { 
        System.out.println("MQTT connection intercepted "); 
      } 
      return true; 
    } 

Mon apache client paho connecter au courtier via ce port « ws: //0.0 .0,0: 61614 ".
Mon problème est que seuls les messages publiés sur des sujets sont interceptés.
Pourquoi cela n'intercepte pas le message CONNECT?

Answer 1

La version actuelle d'ActiveMQ Artemis, 2.2.0, au moment où j'écris cette réponse, prend uniquement en charge l'interception des paquets de contrôle MQTT Publish. I opened a pull request ajoutant cette fonctionnalité, par conséquent, il devrait être présent sur les futures versions.