diff --git a/lib/nodes/mqtt.c b/lib/nodes/mqtt.c index 52ecc1457..bc3692f13 100644 --- a/lib/nodes/mqtt.c +++ b/lib/nodes/mqtt.c @@ -96,6 +96,7 @@ static void mqtt_message_cb(struct mosquitto *mosq, void *userdata, const struct } if (ret != 1) { debug(4, "MQTT: skip empty message for node %s", node_name(n)); + sample_put(smp); return; }