From 7cd5367f3b125120c26b986f53a3cbd4d5dee4f8 Mon Sep 17 00:00:00 2001
From: Feng <ery.lee@gmail.com>
Date: Wed, 16 Dec 2015 11:04:20 +0800
Subject: [PATCH] binary

---
 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 308be6184..d9a1787d7 100644
--- a/src/emqttd_pubsub.erl
+++ b/src/emqttd_pubsub.erl
@@ -150,7 +150,7 @@ create(topic, Topic) when is_binary(Topic) ->
         {aborted, Error} -> {error, Error}
     end;
 
-create(subscription, {SubId, Topic, Qos}) ->
+create(subscription, {SubId, Topic, Qos}) when is_binary(SubId) andalso is_binary(Topic) ->
     case mnesia:transaction(fun add_subscription/2, [SubId, {Topic, Qos}]) of
         {atomic, ok}     -> ok;
         {aborted, Error} -> {error, Error}