Package com.swiftmq.impl.mqtt.v311

Class PacketDecoder

java.lang.Object

com.swiftmq.impl.mqtt.v311.PacketDecoder

public class PacketDecoder
extends Object

Constructor Summary

Constructors

Constructor	Description
PacketDecoder(MqttListener mqttListener, TraceSpace traceSpace, int maxPacketSize)

Method Summary

Modifier and Type	Method	Description
void	dataAvailable(Connection connection, InputStream inputStream)
void	ensureBuffer(int ensureSize)

Methods inherited from class java.lang.Object

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

Constructor Details

PacketDecoder

public PacketDecoder(MqttListener mqttListener,
 TraceSpace traceSpace,
 int maxPacketSize)

Method Details

ensureBuffer

public void ensureBuffer(int ensureSize)

dataAvailable

public void dataAvailable(Connection connection,
 InputStream inputStream)
                   throws IOException

Throws:

IOException