From 3c8de09ba3c66c88d4abc8b60521c001ba7100e5 Mon Sep 17 00:00:00 2001 From: Feng Lee Date: Thu, 23 Mar 2017 15:20:32 +0800 Subject: [PATCH] Rename the env 'queue' to 'mqueue' --- src/emqttd_session.erl | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/emqttd_session.erl b/src/emqttd_session.erl index 41ee456f4..316a97741 100644 --- a/src/emqttd_session.erl +++ b/src/emqttd_session.erl @@ -281,7 +281,7 @@ init([CleanSess, {ClientId, Username}, ClientPid]) -> true = link(ClientPid), init_stats([deliver_msg, enqueue_msg]), {ok, Env} = emqttd:env(session), - {ok, QEnv} = emqttd:env(queue), + {ok, QEnv} = emqttd:env(mqueue), MaxInflight = get_value(max_inflight, Env, 0), EnableStats = get_value(enable_stats, Env, false), ForceGcCount = emqttd_gc:conn_max_gc_count(),