inflight, queued

2015-06-06 19:04:02 +08:00 · 2015-06-06 19:04:02 +08:00 · 789e482a30
parent 0407d902d6
commit 789e482a30
1 changed files with 2 additions and 0 deletions
--- a/apps/emqttd/src/emqttd_session.erl
+++ b/apps/emqttd/src/emqttd_session.erl
@ -57,6 +57,8 @@
        client_pid  :: pid(),
 		message_id  = 1,
        submap      :: map(),
+        inflight_messages,
+        queued_messages,
        msg_queue, %% do not receive rel
        awaiting_ack :: map(),
        awaiting_rel :: map(),