MQTT parser

MQTT parser is a library designed for encoding and decoding of MQTT 3.1.1 packets. It is written in Java. MQTT parser is developed by Mobius Software.

Getting Started

First you should clone MQTT parser. Then you should add the following lines within the element of pom.xml file of your project:

<dependency>
	<groupId>com.mobius.software.mqtt</groupId>
	<artifactId>parser</artifactId>
	<version>0.0.1-SNAPSHOT</version>
</dependency>

Now you are able to start using MQTT parser.

Examples

Create, encode, decode message

try
		{
			// Message creation
			String username = "[email protected]";
			String password = "password";
			String clientID = "dummy-client-1";
			boolean cleanSession = true;
			int keepalive = 10;

			Text topicName = new Text("root/example");
			Topic topic = Topic.valueOf(topicName, QoS.AT_LEAST_ONCE);
			String content = "message";
			boolean retain = false;
			Will will = new Will(topic, content.getBytes(), retain);
			Connect connect = new Connect(username, password, clientID, cleanSession, keepalive, will);

			// Encode message
			ByteBuf encoded = MQParser.encode(connect);
			// process encoded value...

			// Decode message
			MQMessage decoded = MQParser.decode(encoded);
			// process decoded value...
		}
		catch (Exception e)
		{
			e.printStackTrace();
			fail();
		}