diff --git a/src/emqttd_pubsub.erl b/src/emqttd_pubsub.erl
index 0f8d3a2c6..854298873 100644
--- a/src/emqttd_pubsub.erl
+++ b/src/emqttd_pubsub.erl
@@ -239,8 +239,8 @@ init([Id, _Opts]) ->
 
 prioritise_call(Msg, _From, _Len, _State) ->
     case Msg of
-        {subscriber, _, _} -> 1;
-        _                  -> 0
+        {subscribe, _, _} -> 1;
+        _                 -> 0
     end.
 
 prioritise_cast(Msg, _Len, _State) ->