org.apache.activemq.apollo.mqtt

Class MqttSession

java.lang.Object

org.apache.activemq.apollo.mqtt.MqttSession

public class MqttSession
extends Object

An MqttSession can be switch from one connection/protocol handler to another, but it will only be associated with one at a time. An MqttSession tracks the state of the communication with a client.

Author:

Hiram Chirino

Field Summary

Fields

Modifier and Type	Field and Description
boolean	clean_session
org.fusesource.hawtbuf.UTF8Buffer	client_id
org.fusesource.mqtt.codec.CONNECT	connect_message
DestinationParser	destination_parser
MqttProtocolHandler	handler
MqttSessionManager.HostState	host_state
boolean	manager_disconnected
org.fusesource.hawtdispatch.DispatchQueue	queue
org.apache.activemq.apollo.broker.security.SecurityContext	security_context
org.apache.activemq.apollo.mqtt.MqttSessionManager.SessionState	session_state

Constructor Summary

Constructors

Constructor and Description
MqttSession(MqttSessionManager.HostState host_state, org.fusesource.hawtbuf.UTF8Buffer client_id, org.apache.activemq.apollo.mqtt.MqttSessionManager.SessionState session_state)

Method Summary

Methods

Modifier and Type	Method and Description
void	attach()
void	connect(MqttProtocolHandler next)
SimpleAddress	decode_destination(org.fusesource.hawtbuf.UTF8Buffer value)
void	detach()
void	disconnect(MqttProtocolHandler prev)
VirtualHost	host()
void	on_mqtt_publish(org.fusesource.mqtt.codec.PUBLISH publish)
void	on_mqtt_subscribe(org.fusesource.mqtt.codec.SUBSCRIBE sub)
void	on_mqtt_unsubscribe(org.fusesource.mqtt.codec.UNSUBSCRIBE unsubscribe)
void	on_transport_command(Object o)
void	publish_completed(short id)
void	publish_will(org.fusesource.hawtdispatch.Task complete_close)
void	send_via_route(org.apache.activemq.apollo.mqtt.MqttSession.MqttProducerRoute route, org.fusesource.mqtt.codec.PUBLISH publish)
void	send(org.fusesource.mqtt.codec.MessageSupport.Message message)
void	subscribe(Collection<org.fusesource.mqtt.client.Topic> topics, org.fusesource.hawtdispatch.Task on_subscribed)

Methods inherited from class java.lang.Object

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

Field Detail

host_state

public final MqttSessionManager.HostState host_state

client_id

public final org.fusesource.hawtbuf.UTF8Buffer client_id

session_state

public final org.apache.activemq.apollo.mqtt.MqttSessionManager.SessionState session_state

queue

public final org.fusesource.hawtdispatch.DispatchQueue queue

manager_disconnected

public boolean manager_disconnected

handler

public MqttProtocolHandler handler

security_context

public org.apache.activemq.apollo.broker.security.SecurityContext security_context

clean_session

public boolean clean_session

connect_message

public org.fusesource.mqtt.codec.CONNECT connect_message

destination_parser

public DestinationParser destination_parser

Constructor Detail

MqttSession

public MqttSession(MqttSessionManager.HostState host_state,
           org.fusesource.hawtbuf.UTF8Buffer client_id,
           org.apache.activemq.apollo.mqtt.MqttSessionManager.SessionState session_state)

Method Detail

host

public VirtualHost host()

connect

public void connect(MqttProtocolHandler next)

disconnect

public void disconnect(MqttProtocolHandler prev)

attach

public void attach()

detach

public void detach()

decode_destination

public SimpleAddress decode_destination(org.fusesource.hawtbuf.UTF8Buffer value)

send

public void send(org.fusesource.mqtt.codec.MessageSupport.Message message)

publish_completed

public void publish_completed(short id)

on_transport_command

public void on_transport_command(Object o)

on_mqtt_publish

public void on_mqtt_publish(org.fusesource.mqtt.codec.PUBLISH publish)

send_via_route

public void send_via_route(org.apache.activemq.apollo.mqtt.MqttSession.MqttProducerRoute route,
                  org.fusesource.mqtt.codec.PUBLISH publish)

publish_will

public void publish_will(org.fusesource.hawtdispatch.Task complete_close)

on_mqtt_subscribe

public void on_mqtt_subscribe(org.fusesource.mqtt.codec.SUBSCRIBE sub)

subscribe

public void subscribe(Collection<org.fusesource.mqtt.client.Topic> topics,
             org.fusesource.hawtdispatch.Task on_subscribed)

on_mqtt_unsubscribe

public void on_mqtt_unsubscribe(org.fusesource.mqtt.codec.UNSUBSCRIBE unsubscribe)