The MQTT Protocol for Apollo

Overview

This plugin 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

Prequisites

An installation of:

• Apollo 1.1 or 1.2

Installing on Apollo 1.1

Download and copy the fusemq-apollo-mqtt-1.0-uber.jar into the your Apollo's lib directory then restart your broker.

Installing on Apollo 1.2

Download and copy the fusemq-apollo-mqtt-1.1-uber.jar into the your Apollo's lib directory then restart your broker.

Installing on Apollo 1.3

Download and copy the fusemq-apollo-mqtt-1.2-uber.jar into the your Apollo's lib directory then restart your broker.

Installing on Apollo 1.4

Download and copy the fusemq-apollo-mqtt-1.3-uber.jar into the your Apollo's lib directory then restart your broker.

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.