yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix(rule): rename the eventname of bridge sources to $bridges/mqtt:*

This commit is contained in:
Shawn 2022-03-10 23:03:27 +08:00
parent 3ca3470844
commit 5ca0d4f856
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apps/emqx_rule_engine/src/emqx_rule_events.erl
View File

@ -448,7 +448,7 @@ event_info_session_unsubscribed() ->
). ).
event_info_bridge_mqtt()-> event_info_bridge_mqtt()->
event_info_common( event_info_common(
<<"$bridges/mqtt:my_mqtt_bridge">>, <<"$bridges/mqtt:*">>,
{<<"MQTT bridge message">>, <<"MQTT 桥接消息"/utf8>>}, {<<"MQTT bridge message">>, <<"MQTT 桥接消息"/utf8>>},
{<<"received a message from MQTT bridge">>, <<"收到来自 MQTT 桥接的消息"/utf8>>}, {<<"received a message from MQTT bridge">>, <<"收到来自 MQTT 桥接的消息"/utf8>>},
<<"SELECT * FROM \"$bridges/mqtt:my_mqtt_bridge\" WHERE topic =~ 't/#'">> <<"SELECT * FROM \"$bridges/mqtt:my_mqtt_bridge\" WHERE topic =~ 't/#'">>

4
apps/emqx_rule_engine/src/emqx_rule_sqltester.erl
View File

@ -84,8 +84,8 @@ echo_action(Data, Envs) ->
fill_default_values(Event, Context) -> fill_default_values(Event, Context) ->
maps:merge(envs_examp(Event), Context). maps:merge(envs_examp(Event), Context).
envs_examp(EVENT_TOPIC) -> envs_examp(EventTopic) ->
EventName = emqx_rule_events:event_name(EVENT_TOPIC), EventName = emqx_rule_events:event_name(EventTopic),
emqx_rule_maps:atom_key_map( emqx_rule_maps:atom_key_map(
maps:from_list( maps:from_list(
emqx_rule_events:columns_with_exam(EventName))). emqx_rule_events:columns_with_exam(EventName))).