From edb1460b56d152659abebf07692f33bac6fe3dc4 Mon Sep 17 00:00:00 2001 From: JianBo He Date: Sun, 20 Mar 2022 10:18:50 +0800 Subject: [PATCH] chore(rule-engine): more safe generate even_msg content --- apps/emqx_rule_engine/src/emqx_rule_events.erl | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/apps/emqx_rule_engine/src/emqx_rule_events.erl b/apps/emqx_rule_engine/src/emqx_rule_events.erl index 10e3e41ef..de3af52ac 100644 --- a/apps/emqx_rule_engine/src/emqx_rule_events.erl +++ b/apps/emqx_rule_engine/src/emqx_rule_events.erl @@ -191,12 +191,12 @@ eventmsg_connected(_ClientInfo = #{ clean_start := CleanStart, proto_name := ProtoName, proto_ver := ProtoVer, - keepalive := Keepalive, - connected_at := ConnectedAt, - conn_props := ConnProps, - receive_maximum := RcvMax, - expiry_interval := ExpiryInterval + connected_at := ConnectedAt }) -> + Keepalive = maps:get(keepalive, ConnInfo, 0), + ConnProps = maps:get(conn_props, ConnInfo, #{}), + RcvMax = maps:get(receive_maximum, ConnInfo, 0), + ExpiryInterval = maps:get(expiry_interval, ConnInfo, 0), with_basic_columns('client.connected', #{clientid => ClientId, username => Username,