diff --git a/src/emqttd_protocol.erl b/src/emqttd_protocol.erl index b30978ac6..c3905ad5a 100644 --- a/src/emqttd_protocol.erl +++ b/src/emqttd_protocol.erl @@ -552,7 +552,7 @@ sp(false) -> 0. clean_retain(false, Msg = #mqtt_message{retain = true}) -> Msg#mqtt_message{retain = false}; -clean_retain(true, Msg) -> +clean_retain(_IsBridge, Msg) -> Msg. %%--------------------------------------------------------------------