org.apache.activemq.transport.mqtt
public class MQTTCodec extends java.lang.Object
Constructor and Description |
---|
MQTTCodec(TcpTransport transport) |
Modifier and Type | Method and Description |
---|---|
static java.lang.String |
commandType(byte header) |
void |
parse(DataByteArrayInputStream input,
int readSize) |
public MQTTCodec(TcpTransport transport)
public void parse(DataByteArrayInputStream input, int readSize) throws java.lang.Exception
java.lang.Exception
public static java.lang.String commandType(byte header) throws java.io.IOException, javax.jms.JMSException
java.io.IOException
javax.jms.JMSException
Copyright © 2005-2014. All Rights Reserved.