Increase test resiliance
This commit is contained in:
@@ -72,14 +72,16 @@ function generateData(client: mqtt.MqttClient) {
|
|||||||
client.subscribe('kitchen/lamp/set')
|
client.subscribe('kitchen/lamp/set')
|
||||||
client.on('message', (topic, payload) => {
|
client.on('message', (topic, payload) => {
|
||||||
if (topic === 'kitchen/lamp/set') {
|
if (topic === 'kitchen/lamp/set') {
|
||||||
setTimeout(
|
setTimeout(() => {
|
||||||
() =>
|
try {
|
||||||
client.publish('kitchen/lamp/state', JSON.parse(payload.toString()).state, {
|
client.publish('kitchen/lamp/state', JSON.parse(payload.toString()).state, {
|
||||||
retain: true,
|
retain: true,
|
||||||
qos: 0,
|
qos: 0,
|
||||||
}),
|
})
|
||||||
500
|
} catch (error) {
|
||||||
)
|
console.error(error)
|
||||||
|
}
|
||||||
|
}, 500)
|
||||||
}
|
}
|
||||||
})
|
})
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user