I added an mqtt interceptor into my artemis broker in order to intercept mqtt
/public class SimpleMQTTInterceptor implements MQTTInterceptor
public boolean intercept(final MqttMessage mqttMessage,
connection) throws ActiveMQException
System.out.println("MQTT Interceptor gets called ");
if (mqttMessage instanceof MqttConnectMessage)
System.out.println("MQTT connection intercepted ");
My problem is that only message published to topics are intercepted.
Why this doesn't intercept *CONNECT* message ?
View this message in context:
Sent from the ActiveMQ - User mailing list archive at Nabble.com.