From f68b8c40971d8d4fa11235f5d78d30688ad5e874 Mon Sep 17 00:00:00 2001 From: Shawn <506895667@qq.com> Date: Sat, 17 Jul 2021 11:07:46 +0800 Subject: [PATCH] fix(test): update testcases for emqx_gateway --- apps/emqx_gateway/src/stomp/emqx_stomp_channel.erl | 3 ++- apps/emqx_gateway/src/stomp/emqx_stomp_connection.erl | 4 +++- 2 files changed, 5 insertions(+), 2 deletions(-) diff --git a/apps/emqx_gateway/src/stomp/emqx_stomp_channel.erl b/apps/emqx_gateway/src/stomp/emqx_stomp_channel.erl index 4b4feb29d..87bba1939 100644 --- a/apps/emqx_gateway/src/stomp/emqx_stomp_channel.erl +++ b/apps/emqx_gateway/src/stomp/emqx_stomp_channel.erl @@ -113,7 +113,8 @@ init(ConnInfo = #{peername := {PeerHost, _}, Mountpoint = maps:get(mountpoint, Option, undefined), ClientInfo = setting_peercert_infos( Peercert, - #{ zone => undefined + #{ zone => default + , listener => mqtt_tcp , protocol => stomp , peerhost => PeerHost , sockport => SockPort diff --git a/apps/emqx_gateway/src/stomp/emqx_stomp_connection.erl b/apps/emqx_gateway/src/stomp/emqx_stomp_connection.erl index a4b87fcd4..bc149a58d 100644 --- a/apps/emqx_gateway/src/stomp/emqx_stomp_connection.erl +++ b/apps/emqx_gateway/src/stomp/emqx_stomp_connection.erl @@ -245,7 +245,9 @@ init_state(Transport, Socket, Options) -> peername => Peername, sockname => Sockname, peercert => Peercert, - conn_mod => ?MODULE + conn_mod => ?MODULE, + zone => default, + listener => mqtt_tcp }, ActiveN = emqx_gateway_utils:active_n(Options), %% TODO: RateLimit ? How ?