KAZOO-3191 james knows it better.

faphdev · Dec 12, 2014 · 35bdc3b · 35bdc3b
1 parent 67a67ab
commit 35bdc3b
Showing 1 changed file with 1 addition and 4 deletions.
diff --git a/core/whistle_amqp-1.0.0/src/wh_amqp_worker.erl b/core/whistle_amqp-1.0.0/src/wh_amqp_worker.erl
@@ -298,10 +298,7 @@ call_collect(Req, PubFun, UntilFun, Timeout, Worker) ->
 -spec cast(api_terms(), publish_fun()) -> 'ok' | {'error', _}.
 -spec cast(api_terms(), publish_fun(), pid() | atom()) -> 'ok' | {'error', _}.
 cast(Req, PubFun) ->
-    case next_worker() of
-        {'error', _}=E -> E;
-        Worker -> cast(Req, PubFun, Worker)
-    end.
+    cast(Req, PubFun, wh_amqp_sup:pool_name()).
 
 cast(Req, PubFun, Pool) when is_atom(Pool) ->
     case next_worker(Pool) of