Google Git
Sign in
apache / activemq-apollo / refs/heads/trunk / . / apollo-mqtt
tree: 852d51f1fff229f5b500aa93bd0c0a7540ecd13b [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.