diff --git a/src/emqttd_cli.erl b/src/emqttd_cli.erl
index f795ed1be..d9a1642b1 100644
--- a/src/emqttd_cli.erl
+++ b/src/emqttd_cli.erl
@@ -256,7 +256,7 @@ subscriptions(["add", ClientId, Topic, QoS]) ->
                             undefined ->
                                 ?PRINT_MSG("Error: Session not found!");
                             #mqtt_session{sess_pid = SessPid} ->
-                                emqttd_session:subscribe(SessPid, [{bin(Topic), IntQos}]),
+                                emqttd_session:subscribe(SessPid, [{bin(Topic), [{qos, IntQos}]}]),
                                 ?PRINT_MSG("ok~n")
                         end
                      end);