Hivemq Data Hub -

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

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

// 3. Enrich payload payload.timestamp = context.getCurrentTime(); payload.clientId = context.clientId; message) payload.temperature &gt

// 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 ); payload.clientId = context.clientId