org.apache.activemq.artemis.core.protocol.mqtt

Class MQTTConnectionManager

java.lang.Object

org.apache.activemq.artemis.core.protocol.mqtt.MQTTConnectionManager

public class MQTTConnectionManager
extends Object

MQTTConnectionMananager is responsible for handle Connect and Disconnect packets and any resulting behaviour of these events.

Field Summary

Fields

Modifier and Type	Field and Description
static Set<String>	CONNECTED_CLIENTS

Constructor Summary

Constructors

Constructor and Description
MQTTConnectionManager(MQTTSession session)

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

CONNECTED_CLIENTS

public static Set<String> CONNECTED_CLIENTS

Constructor Detail

MQTTConnectionManager

public MQTTConnectionManager(MQTTSession session)