From e7a4be9669c27c606617d5377330a48250d29027 Mon Sep 17 00:00:00 2001 From: Ery Lee Date: Sun, 18 Jan 2015 16:17:41 +0800 Subject: [PATCH] fix get_value --- apps/emqtt/src/emqtt_http.erl | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/apps/emqtt/src/emqtt_http.erl b/apps/emqtt/src/emqtt_http.erl index 481293174..d228f1147 100644 --- a/apps/emqtt/src/emqtt_http.erl +++ b/apps/emqtt/src/emqtt_http.erl @@ -44,8 +44,8 @@ handle(Req) -> handle('POST', "/mqtt/publish", Req) -> Params = mochiweb_request:parse_post(Req), lager:info("HTTP Publish: ~p~n", [Params]), - Qos = int(get_value("qos", "0")), - Retain = bool(get_value("retain", "0")), + Qos = int(get_value("qos", Params, "0")), + Retain = bool(get_value("retain", Params, "0")), Topic = list_to_binary(get_value("topic", Params)), Message = list_to_binary(get_value("message", Params)), case {validate(qos, Qos), validate(topic, Topic)} of