yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

queue:in new message after old one dropped

This commit is contained in:
Feng Lee 2015-06-04 23:13:59 +08:00
parent 7bbd7bb524
commit b544bdc10b
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
apps/emqttd/src/emqttd_queue.erl
View File

@ -25,7 +25,7 @@
%%% @end %%% @end
%%%----------------------------------------------------------------------------- %%%-----------------------------------------------------------------------------
%% TODO: this module should be removed... %% TODO: this module should be rewrited...
-module(emqttd_queue). -module(emqttd_queue).
@ -69,12 +69,12 @@ in(ClientId, Message = #mqtt_message{qos = Qos},
false -> % full false -> % full
if if
Qos =:= ?QOS_0 -> Qos =:= ?QOS_0 ->
lager:warning("Queue ~s drop qos0 message: ~p", [ClientId, Message]), lager:error("Queue ~s drop qos0 message: ~p", [ClientId, Message]),
Wrapper; Wrapper;
true -> true ->
{{value, Msg}, Queue1} = queue:drop(Queue), {{value, Msg}, Queue1} = queue:drop(Queue),
lager:warning("Queue ~s drop message: ~p", [ClientId, Msg]), lager:error("Queue ~s drop message: ~p", [ClientId, Msg]),
Wrapper#mqtt_queue_wrapper{queue = Queue1} Wrapper#mqtt_queue_wrapper{queue = queue:in(Message, Queue1)}
end end
end. end.