Jelajahi Sumber

Fix pick fail

turtled 7 tahun lalu
induk
melakukan
f54d414825
2 mengubah file dengan 2 tambahan dan 2 penghapusan
  1. 1 1
      src/emqx_broker.erl
  2. 1 1
      src/emqx_router.erl

+ 1 - 1
src/emqx_broker.erl

@@ -371,7 +371,7 @@ cast(Broker, Msg) ->
 
 
 %% Pick a broker
 %% Pick a broker
 pick(Topic) ->
 pick(Topic) ->
-    gproc_pool:pick_worker(broker, Topic).
+    gproc_pool:pick_worker(emqx_broker_pool, Topic).
 
 
 %%------------------------------------------------------------------------------
 %%------------------------------------------------------------------------------
 %% gen_server callbacks
 %% gen_server callbacks

+ 1 - 1
src/emqx_router.erl

@@ -148,7 +148,7 @@ call(Router, Msg) ->
     gen_server:call(Router, Msg, infinity).
     gen_server:call(Router, Msg, infinity).
 
 
 pick(Topic) ->
 pick(Topic) ->
-    gproc_pool:pick_worker(router, Topic).
+    gproc_pool:pick_worker(emqx_router_pool, Topic).
 
 
 %%------------------------------------------------------------------------------
 %%------------------------------------------------------------------------------
 %% gen_server callbacks
 %% gen_server callbacks