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