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メッセージを傍受しないのですか?