This article is to explain how to generate an “expired” message and how to catch it in the $expired/#
topic.
\uD83D\uDCD8 Instructions
Prepare a HiveMQ broker with a TCP listener on localhost:1883.
On the broker, enable Expired Messages Topic add-on.
Enabling Expired Messages Topic add-on has 2 workings:The Expired Messages Topic add-on prefaces the topic of expired messages with
$expired/
.
So, if a message published tomy/topic/test
is expired, it will be published to topic$expired/my/topic/test
.The Expired Messages Topic add-on exposes additional metrics in the HiveMQ standard metrics:
com.hivemq.messages.expired-messages
com.hivemq.messages.expired.topic.expired.count
and other metrics.
Following steps explain how to create a situation when a message is expired.
...
is published to the topic
$expired/test
and received by thesub-expired
client.metrics updated
com.hivemq.messages.expired-messages
com.hivemq.messages.expired.topic.expired.count
Info |
---|
Script for quickly setting up a test environment with HiveMQ with Prometheus and Grafana monitoring: https://github.com/guinp1n/docker-hivemq-with-prometheus |