From aed4834aa797c1bfd61a10c9ec32b62e81276f30 Mon Sep 17 00:00:00 2001 From: Feng Lee Date: Sat, 15 Aug 2015 11:15:36 +0800 Subject: [PATCH] comment 'inflight queue is full' --- src/emqttd_session.erl | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/emqttd_session.erl b/src/emqttd_session.erl index a9b4b10ea..2fffcba9a 100644 --- a/src/emqttd_session.erl +++ b/src/emqttd_session.erl @@ -437,7 +437,8 @@ handle_info({dispatch, Msg = #mqtt_message{qos = QoS}}, true -> {noreply, deliver(Msg, Session)}; false -> - lager:error([{client, ClientId}], "Session ~s inflight queue is full!", [ClientId]), + %%TODO: should emit alarm? + %%lager:error([{client, ClientId}], "Session ~s inflight queue is full!", [ClientId]), {noreply, Session#session{message_queue = emqttd_mqueue:in(Msg, MsgQ)}} end;