Receive node is triggered by any message

[tskaard]

It's not possible to get the receive node to timeout when waiting for a specific message from a device.

2019-08-05 21:51:33.632	debug	flow			Next node id = 2
2019-08-05 21:51:33.729	debug	fnode			Reactor-Waiting for event .chan size = 7
2019-08-05 21:51:33.776	info	fnode			New message :
2019-08-05 21:51:33.88	debug	fnode			Reactor-WaitForEvent is stopped
2019-08-05 21:51:33.883	debug	flow			New event from reactor node.
2019-08-05 21:51:33.867	debug	fnode			--New message--
2019-08-05 21:51:33.957	debug	flow			Next node id = 5

Node:
{
"Id": "2",
"Type": "receive",
"Label": "wait for door to close",
"SuccessTransition": "5",
"TimeoutTransition": "7",
"ErrorTransition": "",
"Address": "pt:j1/mt:evt/rt:dev/rn:zw/ad:1/sv:sensor_contact/ad:44_0",
"Service": "sensor_contact",
"ServiceInterface": "evt.open.report",
"Config": {
"IsValueFilterEnabled": false,
"Timeout": 10,
"ValueFilter": {
"Value": "",
"ValueType": ""
}
},
"Ui": {
"nodeType": "",
"x": 212,
"y": 603
}
},

tpflow/node/trigger/fimp/ReceiveNode.go

Line 118 in 05dda84

func (node *ReceiveNode) WaitForEvent(nodeEventStream chan model.ReactorEvent) {

[tskaard]

Logs:
{"level":"debug","msg":"\u003cMqttAd\u003e New msg from TOPIC: pt:j1/mt:evt/rt:dev/rn:zw/ad:1/sv:sensor_presence/ad:23_0","time":"2019-09-26 09:48:28.139"} {"comp":"fnode","fid":"h1Sj2lZnn24SN9Z","level":"debug","msg":"--New message--","nid":"1","ntype":"trigger","time":"2019-09-26 09:48:28.141"} {"comp":"flow","fid":"h1Sj2lZnn24SN9Z","level":"info","msg":" ------Flow Motion trigger started ----------- ","time":"2019-09-26 09:48:28.149"} {"comp":"flow","fid":"h1Sj2lZnn24SN9Z","level":"debug","msg":" Next node id = 3","time":"2019-09-26 09:48:28.171"} {"comp":"fnode","fid":"h1Sj2lZnn24SN9Z","level":"debug","msg":"Operand = eq","nid":"3","ntype":"if","time":"2019-09-26 09:48:28.192"} {"comp":"flow","fid":"h1Sj2lZnn24SN9Z","level":"debug","msg":" Next node id = 5","time":"2019-09-26 09:48:28.195"} {"comp":"fnode","fid":"h1Sj2lZnn24SN9Z","level":"debug","msg":"Operand = eq","nid":"5","ntype":"if","time":"2019-09-26 09:48:28.201"} {"comp":"flow","fid":"h1Sj2lZnn24SN9Z","level":"debug","msg":" Next node id = 2","time":"2019-09-26 09:48:28.206"} {"comp":"fnode","fid":"h1Sj2lZnn24SN9Z","level":"info","msg":"Executing Node . Name = Siren on","nid":"2","ntype":"action","time":"2019-09-26 09:48:28.208"} {"comp":"fnode","fid":"h1Sj2lZnn24SN9Z","level":"debug","msg":" Address: pt:j1/mt:cmd/rt:dev/rn:zw/ad:1/sv:out_bin_switch/ad:16_0","nid":"2","ntype":"action","time":"2019-09-26 09:48:28.214"} {"comp":"fnode","fid":"h1Sj2lZnn24SN9Z","level":"debug","msg":" Action message : {cmd.binary.set out_bin_switch bool true [] [] map[] 1 flow_h1Sj2lZnn24SN9Z }","nid":"2","ntype":"action","time":"2019-09-26 09:48:28.221"} {"level":"debug","msg":"\u003cMqttAd\u003e Publishing msg to topic:pt:j1/mt:cmd/rt:dev/rn:zw/ad:1/sv:out_bin_switch/ad:16_0","time":"2019-09-26 09:48:28.245"} {"comp":"flow","fid":"h1Sj2lZnn24SN9Z","level":"debug","msg":" Next node id = 7","time":"2019-09-26 09:48:28.253"} {"comp":"fnode","fid":"h1Sj2lZnn24SN9Z","level":"debug","msg":"Reactor-Waiting for event .chan size = 1","nid":"7","ntype":"receive","time":"2019-09-26 09:48:28.261"} {"level":"debug","msg":"\u003cMqttAd\u003e New msg from TOPIC: pt:j1/mt:evt/rt:app/rn:vinculum/ad:1","time":"2019-09-26 09:48:28.239"} {"level":"debug","msg":"\u003cMqttAd\u003e New msg from TOPIC: pt:j1/mt:evt/rt:app/rn:vinculum/ad:1","time":"2019-09-26 09:48:28.239"} {"comp":"fnode","fid":"h1Sj2lZnn24SN9Z","level":"info","msg":"New message :","nid":"7","ntype":"receive","time":"2019-09-26 09:48:28.288"} {"comp":"fnode","fid":"h1Sj2lZnn24SN9Z","level":"debug","msg":"Reactor-WaitForEvent is stopped ","nid":"7","ntype":"receive","time":"2019-09-26 09:48:28.379"} {"comp":"fnode","fid":"Vrqhllzzp03GUQy","level":"debug","msg":"--New message--","nid":"1","ntype":"trigger","time":"2019-09-26 09:48:28.323"} {"level":"debug","msg":"New vinc msg","time":"2019-09-26 09:48:28.372"} {"comp":"flow","fid":"h1Sj2lZnn24SN9Z","level":"debug","msg":" New event from reactor node.","time":"2019-09-26 09:48:28.397"} {"level":"debug","msg":"\u003cMqttAd\u003e New msg from TOPIC: pt:j1/mt:evt/rt:app/rn:vinculum/ad:1","time":"2019-09-26 09:48:28.418"} {"level":"debug","msg":"\u003cMqttAd\u003e New msg from TOPIC: pt:j1/mt:evt/rt:app/rn:vinculum/ad:1","time":"2019-09-26 09:48:28.419"} {"comp":"fnode","fid":"Vrqhllzzp03GUQy","level":"debug","msg":"Can't extract value using JPath.Err:key error: current not found in object","nid":"1","ntype":"trigger","time":"2019-09-26 09:48:28.449"} {"comp":"fnode","fid":"Vrqhllzzp03GUQy","level":"debug","msg":"--New message--","nid":"1","ntype":"trigger","time":"2019-09-26 09:48:28.527"} {"comp":"flow","fid":"h1Sj2lZnn24SN9Z","level":"debug","msg":" Next node id = ","time":"2019-09-26 09:48:28.483"} {"level":"debug","msg":"New vinc msg","time":"2019-09-26 09:48:28.526"} {"comp":"fnode","fid":"Vrqhllzzp03GUQy","level":"debug","msg":"Can't extract value using JPath.Err:key error: current not found in object","nid":"1","ntype":"trigger","time":"2019-09-26 09:48:28.544"} {"comp":"flow","fid":"h1Sj2lZnn24SN9Z","level":"info","msg":" ------Flow Motion trigger completed ----------- ","time":"2019-09-26 09:48:28.574"}