From bc72e33056461c118576e04f1295ff50bb156092 Mon Sep 17 00:00:00 2001
From: Feng <ery.lee@gmail.com>
Date: Mon, 8 Aug 2016 14:14:54 +0800
Subject: [PATCH] PubSub:init_tabs

---
 src/emqttd_pubsub_sup.erl | 9 ++++-----
 1 file changed, 4 insertions(+), 5 deletions(-)

diff --git a/src/emqttd_pubsub_sup.erl b/src/emqttd_pubsub_sup.erl
index 5e26ed092..414868fbf 100644
--- a/src/emqttd_pubsub_sup.erl
+++ b/src/emqttd_pubsub_sup.erl
@@ -32,11 +32,10 @@ pubsub_pool() ->
     hd([Pid || {pubsub_pool, Pid, _, _} <- supervisor:which_children(?MODULE)]).
 
 init([Env]) ->
-    {ok, PubSub} = emqttd:conf(pubsub_adapter),
-    PubSubMFA = {PubSub, start_link, [Env]},
-    PoolArgs = [pubsub, hash, pool_size(Env), PubSubMFA],
-    PubSubPoolSup = emqttd_pool_sup:spec(pubsub_pool, PoolArgs),
-    {ok, { {one_for_all, 10, 3600}, [PubSubPoolSup]} }.
+    {ok, PubSub} = emqttd:conf(pubsub_adapter), PubSub:init_tabs(),
+    PoolArgs = [pubsub, hash, pool_size(Env), {PubSub, start_link, [Env]}],
+    PoolSup = emqttd_pool_sup:spec(pubsub_pool, PoolArgs),
+    {ok, { {one_for_all, 10, 3600}, [PoolSup]} }.
 
 pool_size(Env) ->
     Schedulers = erlang:system_info(schedulers),