yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix bool, and route

This commit is contained in:
Ery Lee 2015-01-18 16:22:46 +08:00
parent e7a4be9669
commit 0b09d8a695
1 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
apps/emqtt/src/emqtt_http.erl
View File

@ -50,12 +50,11 @@ handle('POST', "/mqtt/publish", Req) ->
Message = list_to_binary(get_value("message", Params)), Message = list_to_binary(get_value("message", Params)),
case {validate(qos, Qos), validate(topic, Topic)} of case {validate(qos, Qos), validate(topic, Topic)} of
{true, true} -> {true, true} ->
emqtt_pubsub:publish(#mqtt_message { emqtt_router:route(
qos = Qos, #mqtt_message { qos = Qos,
retain = bool(Retain), retain = Retain,
topic = Topic, topic = Topic,
payload = Message payload = Message }),
}),
Req:ok({"text/plan", <<"ok">>}); Req:ok({"text/plan", <<"ok">>});
{false, _} -> {false, _} ->
Req:respond({400, [], <<"Bad QoS">>}); Req:respond({400, [], <<"Bad QoS">>});