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

fix(test): update testcases for emqx_gateway

This commit is contained in:
Shawn 2021-07-17 11:07:46 +08:00
parent f7f2523030
commit f68b8c4097
2 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -113,7 +113,8 @@ init(ConnInfo = #{peername := {PeerHost, _},
Mountpoint = maps:get(mountpoint, Option, undefined), Mountpoint = maps:get(mountpoint, Option, undefined),
ClientInfo = setting_peercert_infos( ClientInfo = setting_peercert_infos(
Peercert, Peercert,
#{ zone => undefined #{ zone => default
, listener => mqtt_tcp
, protocol => stomp , protocol => stomp
, peerhost => PeerHost , peerhost => PeerHost
, sockport => SockPort , sockport => SockPort

4
apps/emqx_gateway/src/stomp/emqx_stomp_connection.erl
View File

@ -245,7 +245,9 @@ init_state(Transport, Socket, Options) ->
peername => Peername, peername => Peername,
sockname => Sockname, sockname => Sockname,
peercert => Peercert, peercert => Peercert,
conn_mod => ?MODULE conn_mod => ?MODULE,
zone => default,
listener => mqtt_tcp
}, },
ActiveN = emqx_gateway_utils:active_n(Options), ActiveN = emqx_gateway_utils:active_n(Options),
%% TODO: RateLimit ? How ? %% TODO: RateLimit ? How ?