From 317ce3cfdf6cbea610b63b38a94580c506fc3f66 Mon Sep 17 00:00:00 2001
From: Feng Lee <ery.lee@gmail.com>
Date: Mon, 8 Aug 2016 14:58:49 +0800
Subject: [PATCH] ok

---
 src/emqttd_session.erl | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/emqttd_session.erl b/src/emqttd_session.erl
index 6f2b3c6dd..8c2bbf8bc 100644
--- 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