Class PacketDecoder

java.lang.Object

com.swiftmq.impl.mqtt.v311.PacketDecoder

All Implemented Interfaces:

com.swiftmq.swiftlet.net.InboundHandler

public class PacketDecoder
extends Object
implements com.swiftmq.swiftlet.net.InboundHandler

Constructor Summary

Constructors

Constructor	Description
PacketDecoder(MqttListener mqttListener, com.swiftmq.swiftlet.trace.TraceSpace traceSpace, int maxPacketSize)

Method Summary

Modifier and Type	Method	Description
void	dataAvailable(com.swiftmq.swiftlet.net.Connection connection, InputStream inputStream)
void	ensureBuffer(int ensureSize)

Methods inherited from class Object

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

Constructor Details

PacketDecoder

public PacketDecoder(MqttListener mqttListener,
 com.swiftmq.swiftlet.trace.TraceSpace traceSpace,
 int maxPacketSize)

Method Details

ensureBuffer

public void ensureBuffer(int ensureSize)

dataAvailable

public void dataAvailable(com.swiftmq.swiftlet.net.Connection connection,
 InputStream inputStream)
                   throws IOException

Specified by:

dataAvailable in interface com.swiftmq.swiftlet.net.InboundHandler

Throws:

IOException