mqtt processing

gistfile1.txt

#!/bin/sh

# Run as a background task

while true  # Keep an infinite loop to reconnect when connection lost/broker unavailable
do
    mosquitto_sub -h localhost -t mqtthost/message/\# -F "%t %p" | while read -r payload
    do
        # Here is the callback to execute whenever you receive a message:
        topic=$(echo "$payload" | cut -d ' ' -f 1)
        msg=$(echo "$payload" | cut -d ' ' -f 2-)
        echo "Rx MQTT: $topic: ${msg}"
    done
    sleep 10  # Wait 10 seconds until reconnection
done