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

Fix get connected_at is undefined

This commit is contained in:
turtled 2019-08-23 20:37:04 +08:00
parent 5cfd8b74bc
commit 29d49b4073
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/emqx_channel.erl
View File

@ -480,14 +480,14 @@ do_unsubscribe(TopicFilter, _SubOpts,
%%-------------------------------------------------------------------- %%--------------------------------------------------------------------
handle_out({connack, ?RC_SUCCESS, SP}, Channel = #channel{client = Client}) -> handle_out({connack, ?RC_SUCCESS, SP}, Channel = #channel{client = Client}) ->
ok = emqx_hooks:run('client.connected',
[Client, ?RC_SUCCESS, attrs(Channel)]),
AckProps = emqx_misc:run_fold([fun enrich_caps/2, AckProps = emqx_misc:run_fold([fun enrich_caps/2,
fun enrich_server_keepalive/2, fun enrich_server_keepalive/2,
fun enrich_assigned_clientid/2 fun enrich_assigned_clientid/2
], #{}, Channel), ], #{}, Channel),
AckPacket = ?CONNACK_PACKET(?RC_SUCCESS, SP, AckProps), AckPacket = ?CONNACK_PACKET(?RC_SUCCESS, SP, AckProps),
Channel1 = ensure_keepalive(AckProps, ensure_connected(Channel)), Channel1 = ensure_keepalive(AckProps, ensure_connected(Channel)),
ok = emqx_hooks:run('client.connected',
[Client, ?RC_SUCCESS, attrs(Channel1)]),
case maybe_resume_session(Channel1) of case maybe_resume_session(Channel1) of
ignore -> {ok, AckPacket, Channel1}; ignore -> {ok, AckPacket, Channel1};
{ok, Publishes, NSession} -> {ok, Publishes, NSession} ->