org.apache.activemq.transport.mqtt

Class MQTTCodec

java.lang.Object

org.apache.activemq.transport.mqtt.MQTTCodec

public class MQTTCodec
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
MQTTCodec(TcpTransport transport)

Method Summary

Methods

Modifier and Type	Method and Description
static java.lang.String	commandType(byte header)
void	parse(org.fusesource.hawtbuf.DataByteArrayInputStream input, int readSize)

Methods inherited from class java.lang.Object

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

Constructor Detail

MQTTCodec

public MQTTCodec(TcpTransport transport)

Method Detail

parse

public void parse(org.fusesource.hawtbuf.DataByteArrayInputStream input,
         int readSize)
           throws java.lang.Exception

Throws:

java.lang.Exception

commandType

public static java.lang.String commandType(byte header)
                                    throws java.io.IOException,
                                           javax.jms.JMSException

Throws:

java.io.IOException

javax.jms.JMSException