org.apache.activemq.apollo.mqtt

Class MqttProtocolHandler

java.lang.Object

org.apache.activemq.apollo.broker.protocol.AbstractProtocolHandler

org.apache.activemq.apollo.mqtt.MqttProtocolHandler

All Implemented Interfaces:

org.apache.activemq.apollo.broker.protocol.ProtocolHandler

public class MqttProtocolHandler
extends org.apache.activemq.apollo.broker.protocol.AbstractProtocolHandler

Author:

Hiram Chirino

Field Summary

Fields

Modifier and Type	Field and Description
static org.apache.activemq.apollo.util.UnitFn1<Object>	dead_handler
static org.apache.activemq.apollo.util.Scala2Java.Logger	log

Constructor Summary

Constructors

Constructor and Description
MqttProtocolHandler()

Method Summary

Methods

Modifier and Type	Method and Description
void	_suspend_read(String reason)
void	async_die(org.fusesource.mqtt.codec.MessageSupport.Message response, String msg)
void	async_die(String msg)
void	async_die(String msg, Throwable e)
Broker	broker()
org.apache.activemq.apollo.util.UnitFn1<Object>	connect_handler()
MqttConnectionStatusDTO	create_connection_status(boolean debug)
DestinationParser	destination_parser()
long	die_delay()
<T> T	die(org.fusesource.mqtt.codec.MessageSupport.Message response)
<T> T	die(org.fusesource.mqtt.codec.MessageSupport.Message response, String msg)
<T> T	die(org.fusesource.mqtt.codec.MessageSupport.Message response, String msg, Throwable e)
<T> T	die(String msg)
<T> T	die(String msg, Throwable e)
void	on_host_connected(VirtualHost host)
void	on_mqtt_connect()
void	on_transport_command(Object command)
void	on_transport_connected()
void	on_transport_disconnected()
void	on_transport_failure(IOException error)
String	protocol()
org.fusesource.hawtdispatch.DispatchQueue	queue()
static <T> T	received(T value)
void	resume_read()
String	session_id()
void	suspend_read(org.apache.activemq.apollo.util.Fn0<String> reason)

Methods inherited from class org.apache.activemq.apollo.broker.protocol.AbstractProtocolHandler

connection_$eq, connection, defer, set_connection

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

dead_handler

public static org.apache.activemq.apollo.util.UnitFn1<Object> dead_handler

Constructor Detail

MqttProtocolHandler

public MqttProtocolHandler()

Method Detail

received

public static <T> T received(T value)

protocol

public String protocol()

broker

public Broker broker()

queue

public org.fusesource.hawtdispatch.DispatchQueue queue()

destination_parser

public DestinationParser destination_parser()

session_id

public String session_id()

on_transport_connected

public void on_transport_connected()

Specified by:

on_transport_connected in interface org.apache.activemq.apollo.broker.protocol.ProtocolHandler

Overrides:

on_transport_connected in class org.apache.activemq.apollo.broker.protocol.AbstractProtocolHandler

on_transport_disconnected

public void on_transport_disconnected()

Specified by:

on_transport_disconnected in interface org.apache.activemq.apollo.broker.protocol.ProtocolHandler

Overrides:

on_transport_disconnected in class org.apache.activemq.apollo.broker.protocol.AbstractProtocolHandler

on_transport_failure

public void on_transport_failure(IOException error)

Specified by:

on_transport_failure in interface org.apache.activemq.apollo.broker.protocol.ProtocolHandler

Overrides:

on_transport_failure in class org.apache.activemq.apollo.broker.protocol.AbstractProtocolHandler

_suspend_read

public void _suspend_read(String reason)

suspend_read

public void suspend_read(org.apache.activemq.apollo.util.Fn0<String> reason)

resume_read

public void resume_read()

die_delay

public long die_delay()

async_die

public void async_die(String msg)

async_die

public void async_die(String msg,
             Throwable e)

async_die

public void async_die(org.fusesource.mqtt.codec.MessageSupport.Message response,
             String msg)

die

public <T> T die(String msg)

die

public <T> T die(String msg,
        Throwable e)

die

public <T> T die(org.fusesource.mqtt.codec.MessageSupport.Message response,
        String msg)

die

public <T> T die(org.fusesource.mqtt.codec.MessageSupport.Message response,
        String msg,
        Throwable e)

die

public <T> T die(org.fusesource.mqtt.codec.MessageSupport.Message response)

on_transport_command

public void on_transport_command(Object command)

Specified by:

on_transport_command in interface org.apache.activemq.apollo.broker.protocol.ProtocolHandler

Overrides:

on_transport_command in class org.apache.activemq.apollo.broker.protocol.AbstractProtocolHandler

connect_handler

public org.apache.activemq.apollo.util.UnitFn1<Object> connect_handler()

on_mqtt_connect

public void on_mqtt_connect()

on_host_connected

public void on_host_connected(VirtualHost host)

create_connection_status

public MqttConnectionStatusDTO create_connection_status(boolean debug)

Specified by:

create_connection_status in interface org.apache.activemq.apollo.broker.protocol.ProtocolHandler

Overrides:

create_connection_status in class org.apache.activemq.apollo.broker.protocol.AbstractProtocolHandler