ok

2016-08-08 14:58:49 +08:00 · 2016-08-08 14:58:49 +08:00 · 317ce3cfdf
parent 28be1e2a00
commit 317ce3cfdf
1 changed files with 2 additions and 2 deletions
--- a/src/emqttd_session.erl
+++ b/src/emqttd_session.erl
@ -175,11 +175,11 @@ subscribe(SessPid, PacketId, TopicTable) ->
 -spec(publish(pid(), mqtt_message()) -> ok | {error, any()}).
 publish(_SessPid, Msg = #mqtt_message{qos = ?QOS_0}) ->
    %% publish qos0 directly
-    emqttd:publish(Msg);
+    emqttd:publish(Msg), ok;

 publish(_SessPid, Msg = #mqtt_message{qos = ?QOS_1}) ->
    %% publish qos1 directly, and client will puback automatically
-    emqttd:publish(Msg);
+    emqttd:publish(Msg), ok;

 publish(SessPid, Msg = #mqtt_message{qos = ?QOS_2}) ->
    %% publish qos2 by session