From 882fbb83ca33c4cc41f6d71868454688eb073b1b Mon Sep 17 00:00:00 2001
From: Feng Lee <ery.lee@gmail.com>
Date: Fri, 12 Jun 2015 10:37:30 +0800
Subject: [PATCH] out

---
 apps/emqttd/src/emqttd_queue.erl | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/apps/emqttd/src/emqttd_queue.erl b/apps/emqttd/src/emqttd_queue.erl
index d9897a3f8..1ca068a13 100644
--- a/apps/emqttd/src/emqttd_queue.erl
+++ b/apps/emqttd/src/emqttd_queue.erl
@@ -72,7 +72,7 @@ in(ClientId, Message = #mqtt_message{qos = Qos},
                     lager:error("Queue ~s drop qos0 message: ~p", [ClientId, Message]),
                     Wrapper;
                 true ->
-                    {{value, Msg}, Queue1} = queue:drop(Queue),
+                    {{value, Msg}, Queue1} = queue:out(Queue),
                     lager:error("Queue ~s drop message: ~p", [ClientId, Msg]),
                     Wrapper#mqtt_queue_wrapper{queue = queue:in(Message, Queue1)}
             end