From fb8a86c5e0270697b66520cdc2ab28b704aab2fc Mon Sep 17 00:00:00 2001
From: terry-xiaoyu <506895667@qq.com>
Date: Thu, 30 Aug 2018 21:58:02 +0800
Subject: [PATCH] delayed will message

---
 src/emqx_protocol.erl | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/src/emqx_protocol.erl b/src/emqx_protocol.erl
index 054bcdf16..5b7c204cd 100644
--- a/src/emqx_protocol.erl
+++ b/src/emqx_protocol.erl
@@ -655,14 +655,14 @@ shutdown(conflict, #pstate{client_id = ClientId}) ->
 shutdown(mnesia_conflict, #pstate{client_id = ClientId}) ->
     emqx_cm:unregister_connection(ClientId),
     ignore;
-shutdown(Error, PState = #pstate{connected = Connected,
+shutdown(Error, PState = #pstate{connected = false}) ->
+    ?LOG(info, "Shutdown for ~p", [Error], PState),
+    ignore;
+shutdown(Error, PState = #pstate{connected = true,
                                  client_id = ClientId,
                                  will_msg = WillMsg}) ->
     ?LOG(info, "Shutdown for ~p", [Error], PState),
-    case Connected of
-        false -> ok;
-        true -> send_willmsg(WillMsg)
-    end,
+    send_willmsg(WillMsg),
     emqx_hooks:run('client.disconnected', [credentials(PState), Error]),
     emqx_cm:unregister_connection(ClientId).