From a0319d9d26568aa10c5bd7f66fd1a16faf48dc71 Mon Sep 17 00:00:00 2001
From: Feng <ery.lee@gmail.com>
Date: Thu, 14 Apr 2016 18:23:01 +0800
Subject: [PATCH] Fix queue dispatch

---
 src/emqttd_pubsub.erl | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/emqttd_pubsub.erl b/src/emqttd_pubsub.erl
index de421cfff..5ccb6bc40 100644
--- a/src/emqttd_pubsub.erl
+++ b/src/emqttd_pubsub.erl
@@ -106,7 +106,7 @@ publish(Topic, Msg) ->
 
 %% @doc Dispatch Message to Subscribers
 -spec(dispatch(binary(), mqtt_message()) -> ok).
-dispatch(Queue = <<"$queue/", _T>>, Msg) ->
+dispatch(Queue = <<"$queue/", _Q/binary>>, Msg) ->
     case subscribers(Queue) of
         [] ->
             dropped(Queue);