Skip to content

Latest commit

 

History

History
40 lines (24 loc) · 1.36 KB

README.md

File metadata and controls

40 lines (24 loc) · 1.36 KB
Raw

Quarkus MQTT Quickstart

This project illustrates how you can interact with MQTT using MicroProfile Reactive Messaging.

MQTT server

First you need a MQTT server. You can follow the instructions from the Eclipse Mosquitto or run docker-compose up if you have docker installed on your machine.

Start the application

The application can be started using:

mvn quarkus:dev

Then, open your browser to http://localhost:8080/prices.html, and you should see a fluctuating price.

Anatomy

In addition to the prices.html page, the application is composed by 3 components:

  • PriceGenerator - a bean generating random price. They are sent to a MQTT topic
  • PriceConverter - on the consuming side, the PriceConverter receives the MQTT message and convert the price. The result is sent to an in-memory stream of data
  • PriceResource - the PriceResource retrieves the in-memory stream of data in which the converted prices are sent and send these prices to the browser using Server-Sent Events.

The interaction with MQTT is managed by MicroProfile Reactive Messaging. The configuration is located in the application configuration.

Running in native

You can compile the application into a native binary using:

mvn clean package -Pnative

and run with:

./target/mqtt-quickstart-1.0-SNAPSHOT-runner