anlicheng/iot
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

ver 5

Browse Source
This commit is contained in:
anlicheng 2023-07-24 11:34:37 +08:00
parent 7e82659103
commit d11c4accca
2 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
apps/iot/src/iot_endpoint.erl
View File

@ -261,7 +261,8 @@ create_postman(#endpoint{name = Name, config = Config = #{<<"protocol">> := <<"m
{password, as_string(Password)}, {password, as_string(Password)},
{keepalive, Keepalive}, {keepalive, Keepalive},
{auto_ack, true}, {auto_ack, true},
{connect_timeout, 5}, {connect_timeout, 5000},
{proto_ver, v5},
{retry_interval, RetryInterval} {retry_interval, RetryInterval}
], ],

2
apps/iot/src/iot_endpoint_sup.erl
View File

@ -17,7 +17,7 @@ start_link() ->
init([]) -> init([]) ->
Specs = lists:map(fun child_spec/1, mnesia_endpoint:get_all_endpoints()), Specs = lists:map(fun child_spec/1, mnesia_endpoint:get_all_endpoints()),
{ok, {#{strategy => one_for_one, intensity => 1000, period => 3600}, []}}. {ok, {#{strategy => one_for_one, intensity => 1000, period => 3600}, Specs}}.
-spec ensured_endpoint_started(Name :: #endpoint{}) -> {ok, Pid :: pid()} | {error, Reason :: any()}. -spec ensured_endpoint_started(Name :: #endpoint{}) -> {ok, Pid :: pid()} | {error, Reason :: any()}.
ensured_endpoint_started(Endpoint = #endpoint{}) -> ensured_endpoint_started(Endpoint = #endpoint{}) ->