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

Merge pull request #7657 from terry-xiaoyu/fix_bridge_issues 

Fix some issues about data bridges
This commit is contained in:
Xinyu Liu 2022-04-18 23:02:21 +08:00 committed by GitHub
parent 6fc471e527 5f74db6d88
commit 7cc99284ba
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
apps/emqx_bridge/src/emqx_bridge.erl
View File

@ -97,11 +97,12 @@ on_message_publish(Message = #message{topic = Topic, flags = Flags}) ->
send_to_matched_egress_bridges(Topic, Msg) -> send_to_matched_egress_bridges(Topic, Msg) ->
lists:foreach(fun (Id) -> lists:foreach(fun (Id) ->
try send_message(Id, Msg) of try send_message(Id, Msg) of
ok -> ok; {error, Reason} ->
Error -> ?SLOG(error, #{msg => "send_message_to_bridge_failed", ?SLOG(error, #{msg => "send_message_to_bridge_failed",
bridge => Id, error => Error}) bridge => Id, error => Reason});
_ -> ok
catch Err:Reason:ST -> catch Err:Reason:ST ->
?SLOG(error, #{msg => "send_message_to_bridge_crash", ?SLOG(error, #{msg => "send_message_to_bridge_exception",
bridge => Id, error => Err, reason => Reason, bridge => Id, error => Err, reason => Reason,
stacktrace => ST}) stacktrace => ST})
end end