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

fix(stomp): sync clientid from clientinfo to conninfo

This commit is contained in:
JianBo He 2022-04-28 22:47:42 +08:00
parent f983ce2562
commit fd5b662302
1 changed files with 12 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
apps/emqx_gateway/src/stomp/emqx_stomp_channel.erl
View File

@ -262,6 +262,17 @@ enrich_clientinfo(
), ),
{ok, NPacket, Channel#channel{clientinfo = NClientInfo}}. {ok, NPacket, Channel#channel{clientinfo = NClientInfo}}.
assign_clientid_to_conninfo(
Packet,
Channel = #channel{
conninfo = ConnInfo,
clientinfo = ClientInfo
}
) ->
ClientId = maps:get(clientid, ClientInfo),
NConnInfo = maps:put(clientid, ClientId, ConnInfo),
{ok, Packet, Channel#channel{conninfo = NConnInfo}}.
feedvar(Override, Packet, ConnInfo, ClientInfo) -> feedvar(Override, Packet, ConnInfo, ClientInfo) ->
Envs = #{ Envs = #{
'ConnInfo' => ConnInfo, 'ConnInfo' => ConnInfo,
@ -409,6 +420,7 @@ handle_in(Packet = ?PACKET(?CMD_CONNECT), Channel) ->
fun run_conn_hooks/2, fun run_conn_hooks/2,
fun negotiate_version/2, fun negotiate_version/2,
fun enrich_clientinfo/2, fun enrich_clientinfo/2,
fun assign_clientid_to_conninfo/2,
fun set_log_meta/2, fun set_log_meta/2,
%% TODO: How to implement the banned in the gateway instance? %% TODO: How to implement the banned in the gateway instance?
%, fun check_banned/2 %, fun check_banned/2