Packages

subscribex

0.10.0-rc.1
0.10.0-rc.1 0.10.0-rc.0 0.9.0 0.8.1 0.8.0 0.8.0-rc.1 0.8.0-rc.0 0.7.0 0.6.0 0.5.0 0.4.0 0.3.0 0.2.0 0.1.0

A high-level library for making RabbitMQ subscribers

HexDocs

Current section

Files

Jump to
Readme
14 Versions
1 Dependency
Dependants
Files
Activity
subscribex lib subscribex publisher pool worker.ex
Raw

lib/subscribex/publisher/pool/worker.ex 

defmodule Subscribex.Publisher.Pool.Worker do

  @moduledoc false



  alias Subscribex.Publisher.Pool

  alias Subscribex.Broker



  def start_link(broker, connection_name) do

    connection = Process.whereis(connection_name)



    %AMQP.Channel{pid: pid} = Broker.channel(connection, :link, broker)



    Pool.add(broker, pid)



    {:ok, pid}

  end

end