From df3d7b628b7a06a1f668bda707bb9d86bc8205ff Mon Sep 17 00:00:00 2001
From: terry-xiaoyu <506895667@qq.com>
Date: Fri, 1 Nov 2019 21:36:30 +0800
Subject: [PATCH] Update emqx_ws_connection for clientinfo

---
 src/emqx_ws_connection.erl | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/src/emqx_ws_connection.erl b/src/emqx_ws_connection.erl
index c5e849c1e..c700cad19 100644
--- a/src/emqx_ws_connection.erl
+++ b/src/emqx_ws_connection.erl
@@ -350,14 +350,14 @@ handle_call(From, Req, State = #state{channel = Channel}) ->
 %% Handle Info
 
 handle_info({connack, ConnAck}, State = #state{channel = Channel}) ->
-    ClientId = emqx_channel:info(clientid, Channel),
+    #{clientid := ClientId} = emqx_channel:info(clientinfo, Channel),
     ok = emqx_cm:register_channel(ClientId),
     ok = emqx_cm:set_chan_attrs(ClientId, attrs(State)),
     ok = emqx_cm:set_chan_stats(ClientId, stats(State)),
     reply(enqueue(ConnAck, State));
 
 handle_info({enter, disconnected}, State = #state{channel = Channel}) ->
-    ClientId = emqx_channel:info(clientid, Channel),
+    #{clientid := ClientId} = emqx_channel:info(clientinfo, Channel),
     emqx_cm:set_chan_attrs(ClientId, attrs(State)),
     emqx_cm:set_chan_stats(ClientId, stats(State)),
     reply(State);
@@ -378,7 +378,7 @@ handle_timeout(TRef, keepalive, State) when is_reference(TRef) ->
 
 handle_timeout(TRef, emit_stats, State = #state{channel = Channel,
                                                 stats_timer = TRef}) ->
-    ClientId = emqx_channel:info(clientid, Channel),
+    #{clientid := ClientId} = emqx_channel:info(clientinfo, Channel),
     (ClientId =/= undefined) andalso emqx_cm:set_chan_stats(ClientId, stats(State)),
     reply(State#state{stats_timer = undefined});