org.fusesource.mqtt.codec

Class MQTTProtocolCodec

java.lang.Object

org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

org.fusesource.mqtt.codec.MQTTProtocolCodec

All Implemented Interfaces:

org.fusesource.hawtdispatch.transport.ProtocolCodec

public class MQTTProtocolCodec
extends org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

Author:

Hiram Chirino

Nested Class Summary

Nested classes/interfaces inherited from class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

org.fusesource.hawtdispatch.transport.AbstractProtocolCodec.Action

Nested classes/interfaces inherited from interface org.fusesource.hawtdispatch.transport.ProtocolCodec

org.fusesource.hawtdispatch.transport.ProtocolCodec.BufferState

Field Summary

Fields inherited from class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

bufferPools, directReadBuffer, lastReadIoSize, lastWriteIoSize, nextDecodeAction, nextWriteBuffer, readBuffer, readBufferPool, readBufferSize, readChannel, readCounter, readEnd, readStart, writeBuffer, writeBufferPool, writeBufferSize, writeChannel, writeCounter

Constructor Summary

Constructors

Constructor and Description
MQTTProtocolCodec()

Method Summary

Modifier and Type	Method and Description
protected void	encode(Object value)
int	getMaxMessageLength()
protected org.fusesource.hawtdispatch.transport.AbstractProtocolCodec.Action	initialDecodeAction()
void	setMaxMessageLength(int maxMessageLength)

Methods inherited from class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

flush, flushNextWriteBuffer, full, getBufferPools, getLastReadSize, getLastWriteSize, getReadBufferSize, getReadCounter, getWriteBufferSize, getWriteCounter, isEmpty, onBufferFlushed, peekBytes, read, readBytes, readDirect, readUntil, readUntil, readUntil, setBufferPools, setTransport, unread, write, writeDirect

Methods inherited from class java.lang.Object

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

Constructor Detail

MQTTProtocolCodec

public MQTTProtocolCodec()

Method Detail

getMaxMessageLength

public int getMaxMessageLength()

setMaxMessageLength

public void setMaxMessageLength(int maxMessageLength)

encode

protected void encode(Object value)
               throws IOException

Specified by:

encode in class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec

Throws:

IOException

initialDecodeAction

protected org.fusesource.hawtdispatch.transport.AbstractProtocolCodec.Action initialDecodeAction()

Specified by:

initialDecodeAction in class org.fusesource.hawtdispatch.transport.AbstractProtocolCodec