From 760d6954b37a70c8d33a678d3d40fb645dd0f7a5 Mon Sep 17 00:00:00 2001 From: Ery Lee Date: Fri, 16 Jan 2015 01:54:33 +0800 Subject: [PATCH] 3.3.1.1 dup: reset dup when route message --- apps/emqtt/src/emqtt_router.erl | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/apps/emqtt/src/emqtt_router.erl b/apps/emqtt/src/emqtt_router.erl index e7e6bf033..be4fbfc06 100644 --- a/apps/emqtt/src/emqtt_router.erl +++ b/apps/emqtt/src/emqtt_router.erl @@ -65,7 +65,7 @@ start_link() -> gen_server:start_link({local, ?SERVER}, ?MODULE, [], []). route(Message) -> - emqtt_pubsub:publish(retained(Message)). + emqtt_pubsub:publish(retained(reset_dup(Message))). %% ------------------------------------------------------------------ %% gen_server Function Definitions @@ -97,3 +97,6 @@ retained(Msg = #mqtt_message{retain = true, topic = Topic}) -> retained(Msg) -> Msg. +reset_dup(Msg = #mqtt_message{dup = true}) -> Msg#mqtt_message{dup = false}; +reset_dup(Msg) -> Msg. +