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

Fix attrs

This commit is contained in:
周子博 2019-08-10 00:37:45 +08:00
parent 0c24bfd78c
commit c2cd43ee18
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/emqx_channel.erl
View File

@ -256,7 +256,7 @@ connected(enter, _PrevSt, State = #state{proto_state = ProtoState}) ->
connected_at = os:timestamp()}, connected_at = os:timestamp()},
ClientId = emqx_protocol:info(client_id, ProtoState), ClientId = emqx_protocol:info(client_id, ProtoState),
ok = emqx_cm:register_channel(ClientId), ok = emqx_cm:register_channel(ClientId),
ok = emqx_cm:set_chan_attrs(ClientId, attrs(NState)), ok = emqx_cm:set_chan_attrs(ClientId, info(NState)),
%% Ensure keepalive after connected successfully. %% Ensure keepalive after connected successfully.
Interval = emqx_protocol:info(keepalive, ProtoState), Interval = emqx_protocol:info(keepalive, ProtoState),
case ensure_keepalive(Interval, NState) of case ensure_keepalive(Interval, NState) of