diff --git a/src/emqttd_pubsub_sup.erl b/src/emqttd_pubsub_sup.erl index 592b8a7d8..f44d56c1f 100644 --- a/src/emqttd_pubsub_sup.erl +++ b/src/emqttd_pubsub_sup.erl @@ -56,7 +56,7 @@ init([Env]) -> %% Router Pool Sup RouterMFA = {emqttd_router, start_link, [fun setstats/1, Env]}, %% Pool_size / 2 - RouterSup = emqttd_pool_sup:spec(router_pool, [router, hash, pool_size(Env) div 2, RouterMFA]), + RouterSup = emqttd_pool_sup:spec(router_pool, [router, hash, 1 + (pool_size(Env) div 2), RouterMFA]), %% PubSub Pool Sup PubSubMFA = {emqttd_pubsub, start_link, [fun setstats/1, Env]},