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

Rename the env 'queue' to 'mqueue'

This commit is contained in:
Feng Lee 2017-03-23 15:20:32 +08:00
parent 06100ae6d5
commit 3c8de09ba3
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/emqttd_session.erl
View File

@ -281,7 +281,7 @@ init([CleanSess, {ClientId, Username}, ClientPid]) ->
true = link(ClientPid), true = link(ClientPid),
init_stats([deliver_msg, enqueue_msg]), init_stats([deliver_msg, enqueue_msg]),
{ok, Env} = emqttd:env(session), {ok, Env} = emqttd:env(session),
{ok, QEnv} = emqttd:env(queue), {ok, QEnv} = emqttd:env(mqueue),
MaxInflight = get_value(max_inflight, Env, 0), MaxInflight = get_value(max_inflight, Env, 0),
EnableStats = get_value(enable_stats, Env, false), EnableStats = get_value(enable_stats, Env, false),
ForceGcCount = emqttd_gc:conn_max_gc_count(), ForceGcCount = emqttd_gc:conn_max_gc_count(),