emqtt
emqtt copied to clipboard
emqx
Erlang MQTT 5.0 Client
From all my clients using this library, and only clients using this library, I regularly get these messages from my mosquito mqtt broker: ``` 1659682346: Client robotica-nerves-f447 has exceeded timeout,...
The purpose of keepalive is to periodically send a ping packet (and check for it's response) so that both sides of the connection know when the connection fails, and they...
I see emqtt once had an automatic reconnect feature but is has been removed. However I haven't found any recommended replacement. Doing a quick test reveals unexpected disconnects (for instance,...
Why I need to execute tho functions for creating a connection? The first one you need to call emqtt:start_link(Opts) and then emqtt:connect(Pid). What's the point in that?
``` ./emqtt_bench pub -c 1 -t aaa -q 2 connected: 1=ERROR REPORT==== 23-Nov-2021::08:40:10.602792 === emqtt(MacBook-Pro_bench_pub_2_515772759): State: connected, Unexpected Event: (cast, {mqtt_packet, {mqtt_packet_header, 5, false, 0, false}, {mqtt_packet_puback, 2, 16, #{}},...
Hello, Just wondering if there are any plans to update the hex package to 1.4.2? https://hex.pm/packages/emqtt Regards
When connection fails you `stop_and_reply` https://github.com/emqx/emqtt/blob/master/src/emqtt.erl#L617-L630 but I would not like this to happen. Depending on the reason, I'd like to just try reconnecting with my own custom logic (like...
application crashes due `{{badarg,[{emqtt,'-timeout_calls/3-fun-0-',4,[{file,"/_build/default/lib/emqtt/src/emqtt.erl"},{line,1131}]},{lists,foldl,3,[{file,"lists.erl"},{line,1263}]},{emqtt,connected,3,[{file,"/_build/default/lib/emqtt/src/emqtt.erl"},{line,935}]},{gen_statem,call_state_function,5,[{file,"gen_statem.erl"},{line,1660}]},{gen_statem,loop_event_state_function,6,[{file,"gen_statem.erl"},{line,1023}]},{proc_lib,init_p_do_apply,3,[{file,"proc_lib.erl"},{line,249}]}]},{gen_statem,call,[,ping,infinity]}}`
