From 0b09d8a695ab5be684c26421d0a58168bbb6fed5 Mon Sep 17 00:00:00 2001
From: Ery Lee <ery.lee@gmail.com>
Date: Sun, 18 Jan 2015 16:22:46 +0800
Subject: [PATCH] fix bool, and route

---
 apps/emqtt/src/emqtt_http.erl | 11 +++++------
 1 file changed, 5 insertions(+), 6 deletions(-)

diff --git a/apps/emqtt/src/emqtt_http.erl b/apps/emqtt/src/emqtt_http.erl
index d228f1147..5994f6b34 100644
--- a/apps/emqtt/src/emqtt_http.erl
+++ b/apps/emqtt/src/emqtt_http.erl
@@ -50,12 +50,11 @@ handle('POST', "/mqtt/publish", Req) ->
     Message = list_to_binary(get_value("message", Params)),
     case {validate(qos, Qos), validate(topic, Topic)} of
         {true, true} ->
-            emqtt_pubsub:publish(#mqtt_message {
-                        qos     = Qos,
-                        retain  = bool(Retain),
-                        topic   = Topic,
-                        payload = Message
-            }),
+            emqtt_router:route(
+                #mqtt_message { qos     = Qos,
+                                retain  = Retain,
+                                topic   = Topic,
+                                payload = Message }),
             Req:ok({"text/plan", <<"ok">>});
        {false, _} ->
             Req:respond({400, [], <<"Bad QoS">>});