fix test

dashbitco · Mar 10, 2025 · 96b9438 · 96b9438
1 parent 214804a
commit 96b9438
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/test/broadway_rabbitmq/ampq_client_test.exs b/test/broadway_rabbitmq/ampq_client_test.exs
@@ -362,8 +362,10 @@ defmodule BroadwayRabbitMQ.AmqpClientTest do
           before_consume: fn _channel -> :bad_return_value end
         )
 
+      assert {:ok, %AMQP.Channel{} = channel} = AmqpClient.setup_channel(config)
+
       message = "unexpected return value from the :before_consume function: :bad_return_value"
-      assert_raise RuntimeError, message, fn -> AmqpClient.setup_channel(config) end
+      assert_raise RuntimeError, message, fn -> AmqpClient.consume(channel, config) end
     end
   end