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(),