Hub [verified]: Hivemq Data

// 3. Enrich payload payload.timestamp = context.getCurrentTime(); payload.clientId = context.clientId;

// 5. Forward original (or transformed) message to original topic return message; // Or return a modified message hivemq data hub

function onMessage(context, message) payload.temperature > 150) context.log.error("Invalid temperature: " + payload.temperature); return null; // Drop invalid reading payload.clientId = context.clientId

// 4. Apply threshold filter & republish to a new topic if high temp if (payload.temperature > 85) var newTopic = "alerts/high-temp"; context.publish(newTopic, payload, qos: 1 ); message) payload.temperature &gt