integration test

compose.yaml

@@ -1,5 +1,6 @@
 services:
   rabbitmq:
-    image: "rabbitmq:alpine"
+    image: "rabbitmq:3.12-management-alpine"
     ports:
       - "5672:5672"
+      - "15672:15672"

config/config.exs

@@ -10,7 +10,20 @@ config :coney,
   },
   workers: [
     FakeConsumer
-  ]
+  ],
+  topology: %{
+    exchanges: [{:topic, "exchange", durable: false}],
+    queues: %{
+      "queue" => %{
+        options: [
+          durable: false
+        ],
+        bindings: [
+          [exchange: "exchange", options: [routing_key: "queue"]]
+        ]
+      }
+    }
+  }
 
 config :logger, level: :info
 

test/lib/coney/coney_test.exs

@@ -0,0 +1,16 @@
+defmodule Coney.ConeyTest do
+  use ExUnit.Case
+  use AMQP
+
+  describe "publish/2" do
+    test "consumes a message" do
+      {:ok, connection} = AMQP.Connection.open(Application.get_env(:coney, :settings)[:url])
+
+      {:ok, channel} = AMQP.Channel.open(connection)
+
+      assert :ok == AMQP.Basic.publish(channel, "exchange", "queue", "message", mandatory: true)
+
+      refute 0 == AMQP.Queue.consumer_count(channel, "queue")
+    end
+  end
+end

test/support/fake_consumer.ex

@@ -18,6 +18,7 @@ defmodule FakeConsumer do
       :reject -> :reject
       :reply -> {:reply, :data}
       :exception -> raise "Exception happen"
+      _other -> :ok
     end
   end