From 0b686da28183bc0634a931d77567a41385b4b282 Mon Sep 17 00:00:00 2001 From: Feng Date: Sun, 24 Jan 2016 13:42:59 +0800 Subject: [PATCH] iolist_to_binary(Name) --- src/emqttd_mqueue.erl | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/emqttd_mqueue.erl b/src/emqttd_mqueue.erl index 866abee09..51227dcf9 100644 --- a/src/emqttd_mqueue.erl +++ b/src/emqttd_mqueue.erl @@ -99,7 +99,8 @@ new(Name, Opts, AlarmFun) -> Type = emqttd_opts:g(type, Opts, simple), MaxLen = emqttd_opts:g(max_length, Opts, infinity), - init_q(#mqueue{type = Type, name = Name, max_len = MaxLen, + init_q(#mqueue{type = Type, name = iolist_to_binary(Name), + len = 0, max_len = MaxLen, low_wm = low_wm(MaxLen, Opts), high_wm = high_wm(MaxLen, Opts), qos0 = emqttd_opts:g(queue_qos0, Opts, false),