diff --git a/src/emqx_broker.erl b/src/emqx_broker.erl index 105589c65..60fb5fd8f 100644 --- a/src/emqx_broker.erl +++ b/src/emqx_broker.erl @@ -371,7 +371,7 @@ cast(Broker, Msg) -> %% Pick a broker pick(Topic) -> - gproc_pool:pick_worker(broker, Topic). + gproc_pool:pick_worker(emqx_broker_pool, Topic). %%------------------------------------------------------------------------------ %% gen_server callbacks diff --git a/src/emqx_router.erl b/src/emqx_router.erl index c165b97ca..0951c82d6 100644 --- a/src/emqx_router.erl +++ b/src/emqx_router.erl @@ -148,7 +148,7 @@ call(Router, Msg) -> gen_server:call(Router, Msg, infinity). pick(Topic) -> - gproc_pool:pick_worker(router, Topic). + gproc_pool:pick_worker(emqx_router_pool, Topic). %%------------------------------------------------------------------------------ %% gen_server callbacks