fix(channel): fix `keep-alive` problem
This commit is contained in:
parent
7bf6ee0f4b
commit
2e30d7803f
|
@ -1545,8 +1545,11 @@ init_alias_maximum(_ConnPkt, _ClientInfo) -> undefined.
|
||||||
%%--------------------------------------------------------------------
|
%%--------------------------------------------------------------------
|
||||||
%% Enrich Keepalive
|
%% Enrich Keepalive
|
||||||
|
|
||||||
ensure_keepalive(#{'Server-Keep-Alive' := Interval}, Channel) ->
|
%% MQTT 5
|
||||||
ensure_keepalive_timer(Interval, Channel);
|
ensure_keepalive(#{'Server-Keep-Alive' := Interval}, Channel = #channel{conninfo = ConnInfo}) ->
|
||||||
|
ensure_keepalive_timer(Interval, Channel#channel{conninfo = ConnInfo#{keepalive => Interval}});
|
||||||
|
|
||||||
|
%% MQTT 3,4
|
||||||
ensure_keepalive(_AckProps, Channel = #channel{conninfo = ConnInfo}) ->
|
ensure_keepalive(_AckProps, Channel = #channel{conninfo = ConnInfo}) ->
|
||||||
ensure_keepalive_timer(maps:get(keepalive, ConnInfo), Channel).
|
ensure_keepalive_timer(maps:get(keepalive, ConnInfo), Channel).
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue