Google Git
Sign in
apache / activemq-apollo / refs/tags/apollo-project-1.7 / . / apollo-mqtt
tree: d6041ff7932cc6d729b8eeec68e2457857792ab2 [path history] [tgz]
  1. src/
  2. pom.xml
  3. readme.md
apollo-mqtt/readme.md

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.