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 ?