example.ex

case Connection.open(amqp_url) do
  {:error, reason} -> # pattern matching
    Logger.error(["Cannot establish connection to RabbitMQ, reason:", inspect(reason)])
    {:error, reason}

  {:ok, connection} -> # pattern matching
    {:ok, channel} = Channel.open(connection) # pattern matching

    Exchange.declare(channel, @exchange, :fanout)

    {:ok, %{queue: queue_name}} = Queue.declare(channel, "", exclusive: true) # pattern matching
    Queue.bind(channel, queue_name, @exchange)

    {:ok, _consumer_tag} = Basic.consume(channel, queue_name, nil, no_ack: true) # pattern matching

    channel
end