Hivemq Data Hub Now

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

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

// 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 ); function onMessage(context, message) payload