org.apache.activemq.apollo.mqtt

Class MqttSessionManager

java.lang.Object

org.apache.activemq.apollo.mqtt.MqttSessionManager

public class MqttSessionManager
extends Object

Tracks active sessions so that we can ensure that a given session id is only associated with once connection at a time. If a client tries to establish a 2nd connection, the first one will be closed before the session is switch to the new connection.

Author:

Hiram Chirino

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MqttSessionManager.HostState

Field Summary

Fields

Modifier and Type	Field and Description
static org.apache.activemq.apollo.util.Scala2Java.Logger	log

Constructor Summary

Constructors

Constructor and Description
MqttSessionManager()

Method Summary

Methods

Modifier and Type	Method and Description
static void	attach(VirtualHost host, org.fusesource.hawtbuf.UTF8Buffer client_id, MqttProtocolHandler handler)
static void	disconnect(MqttSessionManager.HostState host_state, org.fusesource.hawtbuf.UTF8Buffer client_id, MqttProtocolHandler handler)
static void	remove(MqttSessionManager.HostState host_state, org.fusesource.hawtbuf.UTF8Buffer client_id)

Methods inherited from class java.lang.Object

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

Field Detail

log

public static final org.apache.activemq.apollo.util.Scala2Java.Logger log

Constructor Detail

MqttSessionManager

public MqttSessionManager()

Method Detail

attach

public static void attach(VirtualHost host,
          org.fusesource.hawtbuf.UTF8Buffer client_id,
          MqttProtocolHandler handler)

disconnect

public static void disconnect(MqttSessionManager.HostState host_state,
              org.fusesource.hawtbuf.UTF8Buffer client_id,
              MqttProtocolHandler handler)

remove

public static void remove(MqttSessionManager.HostState host_state,
          org.fusesource.hawtbuf.UTF8Buffer client_id)