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

drop

This commit is contained in:
Feng Lee 2015-06-17 11:32:12 +08:00
parent 41e87a5485
commit 02c773bb3f
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apps/emqttd/src/emqttd_mqueue.erl
View File

@ -122,7 +122,7 @@ in({_, #mqtt_message{qos = ?QOS_0}}, MQ = #mqueue{qos0 = false}) ->
in(Msg, MQ = #mqueue{name = Name, q = Q, len = Len, max_len = MaxLen}) in(Msg, MQ = #mqueue{name = Name, q = Q, len = Len, max_len = MaxLen})
when Len =:= MaxLen -> when Len =:= MaxLen ->
{{value, OldMsg}, Q2} = queue:out(Q), {{value, OldMsg}, Q2} = queue:out(Q),
lager:error("MQueue(~s) drop message: ~p", [Name, OldMsg]), lager:error("MQueue(~s) drop ~s", [Name, emqttd_message:format(OldMsg)]),
MQ#mqueue{q = queue:in(Msg, Q2)}; MQ#mqueue{q = queue:in(Msg, Q2)};
in(Msg, MQ = #mqueue{q = Q, len = Len}) -> in(Msg, MQ = #mqueue{q = Q, len = Len}) ->