From b544bdc10b1c31be9f4542b2c9f66863f3f0fc95 Mon Sep 17 00:00:00 2001 From: Feng Lee Date: Thu, 4 Jun 2015 23:13:59 +0800 Subject: [PATCH] queue:in new message after old one dropped --- apps/emqttd/src/emqttd_queue.erl | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/apps/emqttd/src/emqttd_queue.erl b/apps/emqttd/src/emqttd_queue.erl index 34b34a58f..d9897a3f8 100644 --- a/apps/emqttd/src/emqttd_queue.erl +++ b/apps/emqttd/src/emqttd_queue.erl @@ -25,7 +25,7 @@ %%% @end %%%----------------------------------------------------------------------------- -%% TODO: this module should be removed... +%% TODO: this module should be rewrited... -module(emqttd_queue). @@ -69,12 +69,12 @@ in(ClientId, Message = #mqtt_message{qos = Qos}, false -> % full if Qos =:= ?QOS_0 -> - lager:warning("Queue ~s drop qos0 message: ~p", [ClientId, Message]), + lager:error("Queue ~s drop qos0 message: ~p", [ClientId, Message]), Wrapper; true -> {{value, Msg}, Queue1} = queue:drop(Queue), - lager:warning("Queue ~s drop message: ~p", [ClientId, Msg]), - Wrapper#mqtt_queue_wrapper{queue = Queue1} + lager:error("Queue ~s drop message: ~p", [ClientId, Msg]), + Wrapper#mqtt_queue_wrapper{queue = queue:in(Message, Queue1)} end end.