2017-08-11 16 views
0

私はMQTTクライアントの接続を遮断するために、私のアルテミスブローカーにMQTTインターセプタを追加しました:アルテミスブローカーインターセプトMQTTクライアント接続

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; 
    } 

を私のクライアントのapache PAHOは、このポート「WS経由でブローカーに接続します。//0.0 0.0.0:61614」。
私の問題は、トピックに公開されたメッセージだけが傍受されることです。
なぜこれがCONNECTメッセージを傍受しないのですか?

答えて

0

現在のバージョンのActiveMQ Artemis 2.2.0は、この応答を書き込んだ時点で、傍受しているMQTT Publish制御パケットのみをサポートしています。したがって、その機能は将来のバージョンで提供されるはずです。

関連する問題