【发布时间】:2017-08-11 08:28:11
【问题描述】:
我在我的 artemis 代理中添加了一个 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:61614”连接到代理。
我的问题是只有发布到主题的消息才会被拦截。
为什么这不会拦截 CONNECT 消息?
【问题讨论】:
标签: mqtt interceptor paho broker activemq-artemis