Merge pull request #1800 from terry-xiaoyu/ignor_zero_will_delay

Ignore Will-Delay-Interval = 0
emqx · Sep 8, 2018 · c8341c8 · c8341c8
2 parents c0ddbba + 2121da3
commit c8341c8
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/src/emqx_protocol.erl b/src/emqx_protocol.erl
@@ -370,7 +370,7 @@ process_packet(?SUBSCRIBE_PACKET(PacketId, Properties, RawTopicFilters),
                             end;
                            true ->
                                RawTopicFilters
-                        end, 
+                        end,
     case check_subscribe(
            parse_topic_filters(?SUBSCRIBE, RawTopicFilters1), PState) of
         {ok, TopicFilters} ->
@@ -732,7 +732,8 @@ shutdown(Reason, PState = #pstate{connected = true,
 send_willmsg(undefined) ->
     ignore;
 send_willmsg(WillMsg = #message{topic = Topic,
-                                headers = #{'Will-Delay-Interval' := Interval}}) when is_integer(Interval) ->
+                                headers = #{'Will-Delay-Interval' := Interval}})
+            when is_integer(Interval), Interval > 0 ->
     SendAfter = integer_to_binary(Interval),
     emqx_broker:publish(WillMsg#message{topic = <<"$delayed/", SendAfter/binary, "/", Topic/binary>>});
 send_willmsg(WillMsg) ->