diff options
Diffstat (limited to 'lib/poolparty/pool/supervisor.ex')
-rw-r--r-- | lib/poolparty/pool/supervisor.ex | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/lib/poolparty/pool/supervisor.ex b/lib/poolparty/pool/supervisor.ex index 3132f46..751a942 100644 --- a/lib/poolparty/pool/supervisor.ex +++ b/lib/poolparty/pool/supervisor.ex @@ -2,17 +2,17 @@ defmodule PoolParty.Pool.Supervisor do use Supervisor require Logger - def start_link(pool_size, opts \\ []) do + def start_link(pool_size, event_manager, opts \\ []) do Logger.debug("[#{__MODULE__}]: Starting Work Pool Supervisor") - Supervisor.start_link(__MODULE__, {pool_size}, opts) + Supervisor.start_link(__MODULE__, {pool_size, event_manager}, opts) end - def init({pool_size}) do + def init({pool_size, event_manager}) do Logger.debug("[#{__MODULE__}]: Initializing Work Pool Supervisor") children = (1..pool_size) |> Enum.map(fn (id) -> Logger.debug("[#{__MODULE__}]: Starting child worker: #{id}") - worker(PoolParty.Pool.Worker, [], id: id) + worker(PoolParty.Pool.Worker, [event_manager], id: id) end) supervise(children, strategy: :one_for_one) end |