# In config/config.exs
config :my_app, MyApp.Consumer,
  %{name: "my_app_pipeline",
    amqp: %{exchange: "a_exchange", queue: "queue_a",
            uri: "amqp://guest:guest@localhost"}}

# In your supervisor
defmodule MyApp.Supervisor do
  use Supervisor

  def init(_args) do
    children = [worker(MyApp.Consumer, [])]
    supervise(children, [strategy: :one_for_one])
  end
end

# In your consumer module
defmodule MyApp.Consumer do
  use Pipes.Consumer, otp_app: :my_app

  def consume(payload) do
    do_something(payload)
  end
end

# In config/config.exs
config :my_app, MyApp.Producer,
  %{name: "my_app_pipeline",
    amqp: %{exchange: "a_exchange"
            uri: "amqp://guest:guest@localhost"}}

# In your supervisor
defmodule MyApp.Supervisor do
  use Supervisor

  def init(_args) do
    children = [worker(MyApp.Producer, [])]
    supervise(children, [strategy: :one_for_one])
  end
end

# In your consumer module
defmodule MyApp.Producer do
  use Pipes.Producer, otp_app: :my_app
end

# From the module you are interested to publish, a function is available to be called.
MyApp.Producer.publish("my_payload")