Commit 4acb52e

authored

Merge pull request #755 from 3735943886/add_retain_flag_to_mqtt_trigger

Add retain flag to mqtt trigger

2 parents 7e54c83 + 9ae6555 commit 4acb52eCopy full SHA for 4acb52e

File tree

-3

lines changed

-3

lines changed

Lines changed: 1 addition & 0 deletions

Lines changed: 1 addition & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -45,6 +45,7 @@ async def mqtt_message_handler(mqttmsg):`
`45`	`45`	`"topic": mqttmsg.topic,`
`46`	`46`	`"payload": mqttmsg.payload,`
`47`	`47`	`"qos": mqttmsg.qos,`
	`48`	`+ "retain": mqttmsg.retain,`
`48`	`49`	`}`
`49`	`50`
`50`	`51`	`try:`

Lines changed: 4 additions & 3 deletions

Original file line number	Diff line number	Diff line change
@@ -778,13 +778,14 @@ An optional ``str_expr`` can be used to match the MQTT message data, and the tri
`778`	`778`	if that expression evaluates to ``True`` or non-zero. This expression has available these
`779`	`779`	`variables:`
`780`	`780`
`781`		-- ``trigger_type`` is set to "mqtt"
`782`		-- ``topic`` is set to the topic the message was received on
	`781`	+- ``trigger_type`` is set to "mqtt".
	`782`	+- ``topic`` is set to the topic the message was received on.
`783`	`783`	- ``qos`` is set to the message QoS.
`784`		-- ``payload`` is set to the string payload of the message
	`784`	+- ``payload`` is set to the string payload of the message.
`785`	`785`	- ``payload_obj`` if the payload was valid JSON, this will be set to the native Python object
`786`	`786`	`representing that payload. A null message will not be converted. If payload_obj is a`
`787`	`787`	`required function argument an exception will be thrown, use payload_obj=None.`
	`788`	+- ``retain`` is set to the message retain flag. True if the message was retained, False otherwise.
`788`	`789`
`789`	`790`	When the ``@mqtt_trigger`` occurs, those same variables are passed as keyword arguments to the
`790`	`791`	`function in case it needs them. Additional keyword parameters can be specified by setting the`

Comments

(0)