Package org.apache.activemq.transport.mqtt

Class MQTTCodec

java.lang.Object

org.apache.activemq.transport.mqtt.MQTTCodec

public class MQTTCodec
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	MQTTCodec.MQTTFrameSink	Sink for newly decoded MQTT Frames.

Constructor Summary

Constructors

Constructor	Description
MQTTCodec(MQTTCodec.MQTTFrameSink sink)
MQTTCodec(MQTTCodec.MQTTFrameSink sink, MQTTWireFormat wireFormat)
MQTTCodec(TcpTransport transport)
MQTTCodec(TcpTransport transport, MQTTWireFormat wireFormat)

Method Summary

Modifier and Type	Method	Description
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(MQTTCodec.MQTTFrameSink sink)

MQTTCodec

public MQTTCodec(MQTTCodec.MQTTFrameSink sink,
                 MQTTWireFormat wireFormat)

MQTTCodec

public MQTTCodec(TcpTransport transport)

MQTTCodec

public MQTTCodec(TcpTransport transport,
                 MQTTWireFormat wireFormat)

Method Detail

parse

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

Throws:

Exception