The MQTT Protocol for Apollo

Overview

This module adds MQTT v3.1 protocol support to Apache Apollo message brokers. All MQTT v3.1 feature are supported:

• QoS 0, 1, and 2
• Retained messages
• Clean and non-clean sessions
• Client authentication

Validating the Installation

You can use the simple MQTT listener and publisher command line apps included in the mqtt-client library. To use, download the mqtt-client-1.2-uber.jar then in a command line window, run a MQTT message listener on the test topic on your local apollo broker by running:

java -cp mqtt-client-1.2-uber.jar org.fusesource.mqtt.cli.Listener -h tcp://localhost:61613 -u admin -p password  -t test

Then in a seperate command line window then run a publisher to send a hello message to the test topic by running:

java -cp mqtt-client-1.2-uber.jar org.fusesource.mqtt.cli.Publisher -h tcp://localhost:61613 -u admin -p password  -t test -m hello

Your listener's command line process should then print to the screen the hello message.