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

fix(broker): Fix out-of-order message delivery in a cluster 

Fixes: #4658
This commit is contained in:
k32 2021-10-29 09:55:19 +02:00
parent b4c2643291
commit 791caba2ed
3 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
etc/emqx.conf
View File

@ -344,7 +344,7 @@ rpc.port_discovery = stateless
## ##
## Value: Interger [0-256] ## Value: Interger [0-256]
## Default = 1 ## Default = 1
#rpc.tcp_client_num = 1 #rpc.tcp_client_num = 0
## RCP Client connect timeout. ## RCP Client connect timeout.
## ##

2
priv/emqx.schema
View File

@ -376,7 +376,7 @@ end}.
{translation, "gen_rpc.tcp_client_num", fun(Conf) -> {translation, "gen_rpc.tcp_client_num", fun(Conf) ->
case cuttlefish:conf_get("rpc.tcp_client_num", Conf) of case cuttlefish:conf_get("rpc.tcp_client_num", Conf) of
0 -> 1; %% keep allowing 0 for backward compatibility 0 -> max(1, erlang:system_info(schedulers) div 2);
V -> V V -> V
end end
end}. end}.

2
rebar.config
View File

@ -44,7 +44,7 @@
, {cowboy, {git, "https://github.com/emqx/cowboy", {tag, "2.8.2"}}} , {cowboy, {git, "https://github.com/emqx/cowboy", {tag, "2.8.2"}}}
, {esockd, {git, "https://github.com/emqx/esockd", {tag, "5.8.0"}}} , {esockd, {git, "https://github.com/emqx/esockd", {tag, "5.8.0"}}}
, {ekka, {git, "https://github.com/emqx/ekka", {tag, "0.8.1.3"}}} , {ekka, {git, "https://github.com/emqx/ekka", {tag, "0.8.1.3"}}}
, {gen_rpc, {git, "https://github.com/emqx/gen_rpc", {tag, "2.5.1"}}} , {gen_rpc, {git, "https://github.com/emqx/gen_rpc", {tag, "2.6.0"}}}
, {cuttlefish, {git, "https://github.com/emqx/cuttlefish", {tag, "v3.3.6"}}} , {cuttlefish, {git, "https://github.com/emqx/cuttlefish", {tag, "v3.3.6"}}}
, {minirest, {git, "https://github.com/emqx/minirest", {tag, "0.3.7"}}} , {minirest, {git, "https://github.com/emqx/minirest", {tag, "0.3.7"}}}
, {ecpool, {git, "https://github.com/emqx/ecpool", {tag, "0.5.1"}}} , {ecpool, {git, "https://github.com/emqx/ecpool", {tag, "0.5.1"}}}