diff --git a/apps/emqx_gateway_stomp/src/emqx_gateway_stomp.app.src b/apps/emqx_gateway_stomp/src/emqx_gateway_stomp.app.src
index 1fda99700..bcc018ad4 100644
--- a/apps/emqx_gateway_stomp/src/emqx_gateway_stomp.app.src
+++ b/apps/emqx_gateway_stomp/src/emqx_gateway_stomp.app.src
@@ -1,6 +1,6 @@
 {application, emqx_gateway_stomp, [
     {description, "Stomp Gateway"},
-    {vsn, "0.1.1"},
+    {vsn, "0.1.2"},
     {registered, []},
     {applications, [kernel, stdlib, emqx, emqx_gateway]},
     {env, []},
diff --git a/apps/emqx_gateway_stomp/src/emqx_stomp_channel.erl b/apps/emqx_gateway_stomp/src/emqx_stomp_channel.erl
index eef30b3dd..8b7e165d5 100644
--- a/apps/emqx_gateway_stomp/src/emqx_stomp_channel.erl
+++ b/apps/emqx_gateway_stomp/src/emqx_stomp_channel.erl
@@ -695,12 +695,15 @@ check_subscribed_status(
 ) ->
     MountedTopic = emqx_mountpoint:mount(Mountpoint, ParsedTopic),
     case lists:keyfind(SubId, 1, Subs) of
-        {SubId, MountedTopic, _Ack, _} ->
-            ok;
-        {SubId, _OtherTopic, _Ack, _} ->
+        {SubId, _MountedTopic, _Ack, _} ->
             {error, subscription_id_inused};
         false ->
-            ok
+            case lists:keyfind(MountedTopic, 2, Subs) of
+                {_OtherSubId, MountedTopic, _Ack, _} ->
+                    {error, subscription_inused};
+                false ->
+                    ok
+            end
     end.
 
 check_sub_acl(