org.apache.activemq.transport.mqtt
Class MQTTCodec

java.lang.Object
  extended by org.apache.activemq.transport.mqtt.MQTTCodec

public class MQTTCodec
extends java.lang.Object


Constructor Summary
MQTTCodec(TcpTransport transport)
           
 
Method Summary
static java.lang.String commandType(byte header)
           
 void parse(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(TcpTransport transport)
Method Detail

parse

public void parse(DataByteArrayInputStream input,
                  int readSize)
           throws java.lang.Exception
Throws:
java.lang.Exception

commandType

public static java.lang.String commandType(byte header)
                                    throws java.io.IOException,
                                           javax.jms.JMSException
Throws:
java.io.IOException
javax.jms.JMSException


Copyright © 2005-2016. All Rights Reserved.