From d397ae7da1bd9a8a6c6c2894457f1528437a8b09 Mon Sep 17 00:00:00 2001
From: Feng <ery.lee@gmail.com>
Date: Mon, 30 Nov 2015 23:35:46 +0800
Subject: [PATCH] subscribe

---
 src/emqttd_pubsub.erl | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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) ->