From ab9d7232a92ee144f05bbbe629f8ca8d1c9dce0f Mon Sep 17 00:00:00 2001
From: terry-xiaoyu <506895667@qq.com>
Date: Fri, 20 Sep 2019 22:57:01 +0800
Subject: [PATCH] Reset peerport

---
 src/emqx_channel.erl | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/src/emqx_channel.erl b/src/emqx_channel.erl
index da2582fdc..89d3a895d 100644
--- a/src/emqx_channel.erl
+++ b/src/emqx_channel.erl
@@ -172,7 +172,7 @@ set_field(Name, Val, Channel) ->
 %%--------------------------------------------------------------------
 
 -spec(init(emqx_types:conninfo(), proplists:proplist()) -> channel()).
-init(ConnInfo = #{peername := {PeerHost, PeerPort}}, Options) ->
+init(ConnInfo = #{peername := {PeerHost, _Port}}, Options) ->
     Zone = proplists:get_value(zone, Options),
     Peercert = maps:get(peercert, ConnInfo, undefined),
     Username = case peer_cert_as_username(Options) of
@@ -184,7 +184,6 @@ init(ConnInfo = #{peername := {PeerHost, PeerPort}}, Options) ->
     MountPoint = emqx_zone:get_env(Zone, mountpoint),
     ClientInfo = #{zone         => Zone,
                    peerhost     => PeerHost,
-                   peerport     => PeerPort,
                    peercert     => Peercert,
                    client_id    => undefined,
                    username     => Username,