diff --git a/etc/emqx.conf b/etc/emqx.conf index f6ded1032..e7e37f0a0 100644 --- a/etc/emqx.conf +++ b/etc/emqx.conf @@ -2041,7 +2041,7 @@ broker.sys_heartbeat = 30s ## ## Value: Enum ## - local -## - one +## - leader ## - quorum ## - all broker.session_locking_strategy = quorum diff --git a/src/emqx_cm_locker.erl b/src/emqx_cm_locker.erl index 708d3d23c..b5979c706 100644 --- a/src/emqx_cm_locker.erl +++ b/src/emqx_cm_locker.erl @@ -60,7 +60,7 @@ lock(ClientId, Piggyback) -> unlock(ClientId) -> ekka_locker:release(?MODULE, ClientId, strategy()). --spec(strategy() -> local | one | quorum | all). +-spec(strategy() -> local | leader | quorum | all). strategy() -> emqx:get_env(session_locking_strategy, quorum).