diff --git a/.credo.exs b/.credo.exs index c852807..cd54180 100644 --- a/.credo.exs +++ b/.credo.exs @@ -33,7 +33,7 @@ # If you want to enforce a style guide and need a more traditional linting # experience, you can change `strict` to `true` below: # - strict: false, + strict: true, # # If you want to use uncolored output by default, you can change `color` # to `false` below: diff --git a/.dialyzerignore b/.dialyzerignore index f4e0fee..e69de29 100644 --- a/.dialyzerignore +++ b/.dialyzerignore @@ -1,3 +0,0 @@ -:0: Unknown function 'Elixir.ExUnit.Callbacks':'__merge__'/3 -:0: Unknown function 'Elixir.ExUnit.Callbacks':on_exit/1 -:0: Unknown function 'Elixir.ExUnit.CaseTemplate':'__proxy__'/2 diff --git a/Dockerfile b/Dockerfile index b282cd0..862e51d 100644 --- a/Dockerfile +++ b/Dockerfile @@ -1,4 +1,4 @@ -FROM public.ecr.aws/prima/elixir:1.11.2-1 +FROM public.ecr.aws/prima/elixir:1.12.0-1 WORKDIR /code diff --git a/mix.exs b/mix.exs index fa8df37..c7d5f5b 100644 --- a/mix.exs +++ b/mix.exs @@ -5,7 +5,7 @@ defmodule Amqpx.MixProject do [ app: :amqpx, name: "amqpx", - version: "5.5.0", + version: "5.6.0", elixir: "~> 1.7", elixirc_paths: elixirc_paths(Mix.env()), start_permanent: Mix.env() == :production, @@ -37,11 +37,12 @@ defmodule Amqpx.MixProject do [ check: [ "format --check-formatted mix.exs \"lib/**/*.{ex,exs}\" \"test/**/*.{ex,exs}\" \"priv/**/*.{ex,exs}\" \"config/**/*.{ex,exs}\"", + "deps.unlock --check-unused", "credo", "dialyzer" ], "format.all": [ - "format mix.exs \"lib/**/*.{ex,exs}\" \"test/**/*.{ex,exs}\" \"priv/**/*.{ex,exs}\" \"config/**/*.{ex,exs}\"" + "format mix.exs \"lib/**/*.{ex,exs}\" \"test/**/*.{ex,exs}\" \"config/**/*.{ex,exs}\"" ] ] end @@ -49,12 +50,12 @@ defmodule Amqpx.MixProject do # Run "mix help deps" to learn about dependencies. defp deps do [ - {:amqp_client, "~> 3.7.20"}, - {:rabbit_common, "~> 3.7.20"}, - {:elixir_uuid, "~> 1.1"}, - {:credo, "~> 1.1", only: [:dev, :test]}, - {:mock, "~> 0.3.0", only: :test}, - {:dialyxir, "~> 1.0.0-rc", only: [:dev, :test], runtime: false}, + {:amqp_client, "~> 3.8"}, + {:rabbit_common, "~> 3.8"}, + {:elixir_uuid, "~> 1.2"}, + {:credo, "~> 1.5", only: [:dev, :test]}, + {:mock, "~> 0.3.7", only: :test}, + {:dialyxir, "~> 1.1", only: [:dev, :test], runtime: false}, {:ex_doc, ">= 0.0.0", only: :dev, runtime: false} ] end diff --git a/mix.lock b/mix.lock index 7b6e6af..43ec2e2 100644 --- a/mix.lock +++ b/mix.lock @@ -1,24 +1,24 @@ %{ - "amqp_client": {:hex, :amqp_client, "3.7.24", "9d336f9a425cbb5f6ffefa586012c3d3f68a72e934c9ef0f41e2764fa92dc84c", [:make, :rebar3], [{:rabbit_common, "3.7.24", [hex: :rabbit_common, repo: "hexpm", optional: false]}], "hexpm", "27fcbbd7b43498a4041b4869837e2b2c1d27ab730c9b58a84d633360f9e0b4af"}, + "amqp_client": {:hex, :amqp_client, "3.8.14", "7569517aefb47e0d1c41bca2f4768dc8a2d88487daf7819fecca0d78943f293c", [:make, :rebar3], [{:rabbit_common, "3.8.14", [hex: :rabbit_common, repo: "hexpm", optional: false]}], "hexpm", "e5ba3ac18abbe34a1d990a6bcac25633dc7061ab8f8d101c7dcff97f49f4c523"}, "bunt": {:hex, :bunt, "0.2.0", "951c6e801e8b1d2cbe58ebbd3e616a869061ddadcc4863d0a2182541acae9a38", [:mix], [], "hexpm", "7af5c7e09fe1d40f76c8e4f9dd2be7cebd83909f31fee7cd0e9eadc567da8353"}, - "credentials_obfuscation": {:hex, :credentials_obfuscation, "1.1.0", "513793cc20c18afc9e03e584b436192a751a8344890e03a8741c65c8d6866fab", [:rebar3], [], "hexpm", "2d1bc574d129ff76309a03874c245193c6375bc766734e008888e636b250d5df"}, - "credo": {:hex, :credo, "1.3.2", "08d456dcf3c24da162d02953fb07267e444469d8dad3a2ae47794938ea467b3a", [:mix], [{:bunt, "~> 0.2.0", [hex: :bunt, repo: "hexpm", optional: false]}, {:jason, "~> 1.0", [hex: :jason, repo: "hexpm", optional: false]}], "hexpm", "b11d28cce1f1f399dddffd42d8e21dcad783309e230f84b70267b1a5546468b6"}, - "dialyxir": {:hex, :dialyxir, "1.0.0", "6a1fa629f7881a9f5aaf3a78f094b2a51a0357c843871b8bc98824e7342d00a5", [:mix], [{:erlex, ">= 0.2.6", [hex: :erlex, repo: "hexpm", optional: false]}], "hexpm", "aeb06588145fac14ca08d8061a142d52753dbc2cf7f0d00fc1013f53f8654654"}, + "credentials_obfuscation": {:hex, :credentials_obfuscation, "2.4.0", "9fb57683b84899ca3546b384e59ab5d3054a9f334eba50d74c82cd0ae82dd6ca", [:rebar3], [], "hexpm", "d28a89830e30698b075de9a4dbe683a20685c6bed1e3b7df744a0c06e6ff200a"}, + "credo": {:hex, :credo, "1.5.5", "e8f422026f553bc3bebb81c8e8bf1932f498ca03339856c7fec63d3faac8424b", [:mix], [{:bunt, "~> 0.2.0", [hex: :bunt, repo: "hexpm", optional: false]}, {:file_system, "~> 0.2.8", [hex: :file_system, repo: "hexpm", optional: false]}, {:jason, "~> 1.0", [hex: :jason, repo: "hexpm", optional: false]}], "hexpm", "dd8623ab7091956a855dc9f3062486add9c52d310dfd62748779c4315d8247de"}, + "dialyxir": {:hex, :dialyxir, "1.1.0", "c5aab0d6e71e5522e77beff7ba9e08f8e02bad90dfbeffae60eaf0cb47e29488", [:mix], [{:erlex, ">= 0.2.6", [hex: :erlex, repo: "hexpm", optional: false]}], "hexpm", "07ea8e49c45f15264ebe6d5b93799d4dd56a44036cf42d0ad9c960bc266c0b9a"}, "earmark_parser": {:hex, :earmark_parser, "1.4.13", "0c98163e7d04a15feb62000e1a891489feb29f3d10cb57d4f845c405852bbef8", [:mix], [], "hexpm", "d602c26af3a0af43d2f2645613f65841657ad6efc9f0e361c3b6c06b578214ba"}, "elixir_uuid": {:hex, :elixir_uuid, "1.2.1", "dce506597acb7e6b0daeaff52ff6a9043f5919a4c3315abb4143f0b00378c097", [:mix], [], "hexpm", "f7eba2ea6c3555cea09706492716b0d87397b88946e6380898c2889d68585752"}, "erlex": {:hex, :erlex, "0.2.6", "c7987d15e899c7a2f34f5420d2a2ea0d659682c06ac607572df55a43753aa12e", [:mix], [], "hexpm", "2ed2e25711feb44d52b17d2780eabf998452f6efda104877a3881c2f8c0c0c75"}, "ex_doc": {:hex, :ex_doc, "0.24.2", "e4c26603830c1a2286dae45f4412a4d1980e1e89dc779fcd0181ed1d5a05c8d9", [:mix], [{:earmark_parser, "~> 1.4.0", [hex: :earmark_parser, repo: "hexpm", optional: false]}, {:makeup_elixir, "~> 0.14", [hex: :makeup_elixir, repo: "hexpm", optional: false]}, {:makeup_erlang, "~> 0.1", [hex: :makeup_erlang, repo: "hexpm", optional: false]}], "hexpm", "e134e1d9e821b8d9e4244687fb2ace58d479b67b282de5158333b0d57c6fb7da"}, + "file_system": {:hex, :file_system, "0.2.10", "fb082005a9cd1711c05b5248710f8826b02d7d1784e7c3451f9c1231d4fc162d", [:mix], [], "hexpm", "41195edbfb562a593726eda3b3e8b103a309b733ad25f3d642ba49696bf715dc"}, "goldrush": {:hex, :goldrush, "0.1.9", "f06e5d5f1277da5c413e84d5a2924174182fb108dabb39d5ec548b27424cd106", [:rebar3], [], "hexpm", "99cb4128cffcb3227581e5d4d803d5413fa643f4eb96523f77d9e6937d994ceb"}, - "jason": {:hex, :jason, "1.2.0", "10043418c42d2493d0ee212d3fddd25d7ffe484380afad769a0a38795938e448", [:mix], [{:decimal, "~> 1.0", [hex: :decimal, repo: "hexpm", optional: true]}], "hexpm", "116747dbe057794c3a3e4e143b7c8390b29f634e16c78a7f59ba75bfa6852e7f"}, - "jsx": {:hex, :jsx, "2.9.0", "d2f6e5f069c00266cad52fb15d87c428579ea4d7d73a33669e12679e203329dd", [:mix, :rebar3], [], "hexpm", "8ee1db1cabafdd578a2776a6aaae87c2a8ce54b47b59e9ec7dab5d7eb71cd8dc"}, - "lager": {:hex, :lager, "3.8.0", "3402b9a7e473680ca179fc2f1d827cab88dd37dd1e6113090c6f45ef05228a1c", [:rebar3], [{:goldrush, "0.1.9", [hex: :goldrush, repo: "hexpm", optional: false]}], "hexpm", "f6cb541b688eab60730d8d286eb77256a5a9ad06eac10d43beaf55d07e68bbb6"}, + "jason": {:hex, :jason, "1.2.2", "ba43e3f2709fd1aa1dce90aaabfd039d000469c05c56f0b8e31978e03fa39052", [:mix], [{:decimal, "~> 1.0 or ~> 2.0", [hex: :decimal, repo: "hexpm", optional: true]}], "hexpm", "18a228f5f0058ee183f29f9eae0805c6e59d61c3b006760668d8d18ff0d12179"}, + "jsx": {:hex, :jsx, "2.11.0", "08154624050333919b4ac1b789667d5f4db166dc50e190c4d778d1587f102ee0", [:rebar3], [], "hexpm", "eed26a0d04d217f9eecefffb89714452556cf90eb38f290a27a4d45b9988f8c0"}, + "lager": {:hex, :lager, "3.8.2", "b180b814fd8b7082b6ca8aaf287e55a908d304cfc7a240d32f4db2d07092b7d0", [:rebar3], [{:goldrush, "0.1.9", [hex: :goldrush, repo: "hexpm", optional: false]}], "hexpm", "73329ce700410b423f64aafc5f94583073904899098e4461f3558ed2980462ab"}, "makeup": {:hex, :makeup, "1.0.5", "d5a830bc42c9800ce07dd97fa94669dfb93d3bf5fcf6ea7a0c67b2e0e4a7f26c", [:mix], [{:nimble_parsec, "~> 0.5 or ~> 1.0", [hex: :nimble_parsec, repo: "hexpm", optional: false]}], "hexpm", "cfa158c02d3f5c0c665d0af11512fed3fba0144cf1aadee0f2ce17747fba2ca9"}, "makeup_elixir": {:hex, :makeup_elixir, "0.15.1", "b5888c880d17d1cc3e598f05cdb5b5a91b7b17ac4eaf5f297cb697663a1094dd", [:mix], [{:makeup, "~> 1.0", [hex: :makeup, repo: "hexpm", optional: false]}, {:nimble_parsec, "~> 1.1", [hex: :nimble_parsec, repo: "hexpm", optional: false]}], "hexpm", "db68c173234b07ab2a07f645a5acdc117b9f99d69ebf521821d89690ae6c6ec8"}, "makeup_erlang": {:hex, :makeup_erlang, "0.1.1", "3fcb7f09eb9d98dc4d208f49cc955a34218fc41ff6b84df7c75b3e6e533cc65f", [:mix], [{:makeup, "~> 1.0", [hex: :makeup, repo: "hexpm", optional: false]}], "hexpm", "174d0809e98a4ef0b3309256cbf97101c6ec01c4ab0b23e926a9e17df2077cbb"}, - "meck": {:hex, :meck, "0.8.13", "ffedb39f99b0b99703b8601c6f17c7f76313ee12de6b646e671e3188401f7866", [:rebar3], [], "hexpm", "d34f013c156db51ad57cc556891b9720e6a1c1df5fe2e15af999c84d6cebeb1a"}, - "mock": {:hex, :mock, "0.3.4", "c5862eb3b8c64237f45f586cf00c9d892ba07bb48305a43319d428ce3c2897dd", [:mix], [{:meck, "~> 0.8.13", [hex: :meck, repo: "hexpm", optional: false]}], "hexpm", "e6d886252f1a41f4ba06ecf2b4c8d38760b34b1c08a11c28f7397b2e03995964"}, + "meck": {:hex, :meck, "0.9.2", "85ccbab053f1db86c7ca240e9fc718170ee5bda03810a6292b5306bf31bae5f5", [:rebar3], [], "hexpm", "81344f561357dc40a8344afa53767c32669153355b626ea9fcbc8da6b3045826"}, + "mock": {:hex, :mock, "0.3.7", "75b3bbf1466d7e486ea2052a73c6e062c6256fb429d6797999ab02fa32f29e03", [:mix], [{:meck, "~> 0.9.2", [hex: :meck, repo: "hexpm", optional: false]}], "hexpm", "4da49a4609e41fd99b7836945c26f373623ea968cfb6282742bcb94440cf7e5c"}, "nimble_parsec": {:hex, :nimble_parsec, "1.1.0", "3a6fca1550363552e54c216debb6a9e95bd8d32348938e13de5eda962c0d7f89", [:mix], [], "hexpm", "08eb32d66b706e913ff748f11694b17981c0b04a33ef470e33e11b3d3ac8f54b"}, - "rabbit_common": {:hex, :rabbit_common, "3.7.24", "d06fa24492daa5c39f1811437f908448f189d965935e7e8070d67856dcb9c3ce", [:make, :rebar3], [{:credentials_obfuscation, "1.1.0", [hex: :credentials_obfuscation, repo: "hexpm", optional: false]}, {:jsx, "2.9.0", [hex: :jsx, repo: "hexpm", optional: false]}, {:lager, "3.8.0", [hex: :lager, repo: "hexpm", optional: false]}, {:ranch, "1.7.1", [hex: :ranch, repo: "hexpm", optional: false]}, {:recon, "2.5.0", [hex: :recon, repo: "hexpm", optional: false]}], "hexpm", "012185b70d520b2faddd427902e6cc793657cc659d527f098f457fa3c3dee2a7"}, - "ranch": {:hex, :ranch, "1.7.1", "6b1fab51b49196860b733a49c07604465a47bdb78aa10c1c16a3d199f7f8c881", [:rebar3], [], "hexpm", "451d8527787df716d99dc36162fca05934915db0b6141bbdac2ea8d3c7afc7d7"}, - "recon": {:hex, :recon, "2.5.0", "2f7fcbec2c35034bade2f9717f77059dc54eb4e929a3049ca7ba6775c0bd66cd", [:mix, :rebar3], [], "hexpm", "72f3840fedd94f06315c523f6cecf5b4827233bed7ae3fe135b2a0ebeab5e196"}, + "rabbit_common": {:hex, :rabbit_common, "3.8.14", "cc1604891295cd82f34597f1526ac611ea7b6a0e57b3dd79b41cb4224bcc6ec5", [:make, :rebar3], [{:credentials_obfuscation, "2.4.0", [hex: :credentials_obfuscation, repo: "hexpm", optional: false]}, {:jsx, "2.11.0", [hex: :jsx, repo: "hexpm", optional: false]}, {:lager, "3.8.2", [hex: :lager, repo: "hexpm", optional: false]}, {:recon, "2.5.1", [hex: :recon, repo: "hexpm", optional: false]}], "hexpm", "27409e425413cdd3fc2c077cf08226c4a307d56b1467883f26ab3789b2e106d0"}, + "recon": {:hex, :recon, "2.5.1", "430ffa60685ac1efdfb1fe4c97b8767c92d0d92e6e7c3e8621559ba77598678a", [:mix, :rebar3], [], "hexpm", "5721c6b6d50122d8f68cccac712caa1231f97894bab779eff5ff0f886cb44648"}, } diff --git a/test/basic_test.exs b/test/basic_test.exs index 78e4b2d..33bd0ec 100644 --- a/test/basic_test.exs +++ b/test/basic_test.exs @@ -4,7 +4,7 @@ defmodule BasicTest do alias Amqpx.{Basic, Connection, Channel, Queue} setup do - {:ok, conn} = Connection.open(Application.get_env(:amqpx, :amqp_connection)) + {:ok, conn} = Connection.open(Application.fetch_env!(:amqpx, :amqp_connection)) {:ok, chan} = Channel.open(conn) on_exit(fn -> diff --git a/test/channel_test.exs b/test/channel_test.exs index 914859b..b5b5c9b 100644 --- a/test/channel_test.exs +++ b/test/channel_test.exs @@ -4,7 +4,7 @@ defmodule ChannelTest do alias Amqpx.{Channel, Connection} setup do - {:ok, conn} = Connection.open(Application.get_env(:amqpx, :amqp_connection)) + {:ok, conn} = Connection.open(Application.fetch_env!(:amqpx, :amqp_connection)) on_exit(fn -> :ok = Connection.close(conn) end) {:ok, conn: conn} end diff --git a/test/confirm_test.exs b/test/confirm_test.exs index 811c4c8..27d88ec 100644 --- a/test/confirm_test.exs +++ b/test/confirm_test.exs @@ -4,7 +4,7 @@ defmodule ConfirmTest do alias Amqpx.{Basic, Confirm, Connection, Channel} setup do - {:ok, conn} = Connection.open(Application.get_env(:amqpx, :amqp_connection)) + {:ok, conn} = Connection.open(Application.fetch_env!(:amqpx, :amqp_connection)) {:ok, chan} = Channel.open(conn) :ok = Confirm.select(chan) diff --git a/test/exchange_test.exs b/test/exchange_test.exs index ffda4fc..32d7033 100644 --- a/test/exchange_test.exs +++ b/test/exchange_test.exs @@ -4,7 +4,7 @@ defmodule ExchangeTest do alias Amqpx.{Channel, Connection, Exchange} setup do - {:ok, conn} = Connection.open(Application.get_env(:amqpx, :amqp_connection)) + {:ok, conn} = Connection.open(Application.fetch_env!(:amqpx, :amqp_connection)) {:ok, chan} = Channel.open(conn) on_exit(fn -> :ok = Connection.close(conn) end) {:ok, conn: conn, chan: chan} diff --git a/test/gen_test.exs b/test/gen_test.exs index 53a3e96..21ccc3d 100644 --- a/test/gen_test.exs +++ b/test/gen_test.exs @@ -1,18 +1,23 @@ defmodule Amqpx.Test.AmqpxTest do use ExUnit.Case - alias Amqpx.Test.Support.{Consumer1, Consumer2, Producer1, Producer2, Producer3} + alias Amqpx.Test.Support.Consumer1 + alias Amqpx.Test.Support.Consumer2 + alias Amqpx.Test.Support.Producer1 + alias Amqpx.Test.Support.Producer2 + alias Amqpx.Test.Support.Producer3 + import Mock setup_all do Amqpx.Gen.ConnectionManager.start_link(%{ - connection_params: Application.get_env(:amqpx, :amqp_connection) + connection_params: Application.fetch_env!(:amqpx, :amqp_connection) }) - {:ok, _} = Amqpx.Gen.Producer.start_link(Application.get_env(:amqpx, :producer)) - {:ok, _} = Amqpx.Gen.Producer.start_link(Application.get_env(:amqpx, :producer2)) + {:ok, _} = Amqpx.Gen.Producer.start_link(Application.fetch_env!(:amqpx, :producer)) + {:ok, _} = Amqpx.Gen.Producer.start_link(Application.fetch_env!(:amqpx, :producer2)) - Enum.each(Application.get_env(:amqpx, :consumers), &Amqpx.Gen.Consumer.start_link(&1)) + Enum.each(Application.fetch_env!(:amqpx, :consumers), &Amqpx.Gen.Consumer.start_link(&1)) :timer.sleep(1_000) :ok diff --git a/test/queue_test.exs b/test/queue_test.exs index 885a3f8..a1f9468 100644 --- a/test/queue_test.exs +++ b/test/queue_test.exs @@ -4,7 +4,7 @@ defmodule QueueTest do alias Amqpx.{Channel, Connection, Exchange, Queue} setup do - {:ok, conn} = Connection.open(Application.get_env(:amqpx, :amqp_connection)) + {:ok, conn} = Connection.open(Application.fetch_env!(:amqpx, :amqp_connection)) {:ok, chan} = Channel.open(conn) on_exit(fn -> :ok = Connection.close(conn) end) {:ok, conn: conn, chan: chan} diff --git a/test/return_test.exs b/test/return_test.exs index a6ce464..823a715 100644 --- a/test/return_test.exs +++ b/test/return_test.exs @@ -4,7 +4,7 @@ defmodule ReturnTest do alias Amqpx.{Basic, Confirm, Connection, Channel} setup do - {:ok, conn} = Connection.open(Application.get_env(:amqpx, :amqp_connection)) + {:ok, conn} = Connection.open(Application.fetch_env!(:amqpx, :amqp_connection)) {:ok, chan} = Channel.open(conn) :ok = Confirm.select(chan) diff --git a/test/support/consumer/consumer_1.ex b/test/support/consumer/consumer_1.ex index 77419a6..4507794 100644 --- a/test/support/consumer/consumer_1.ex +++ b/test/support/consumer/consumer_1.ex @@ -2,14 +2,12 @@ defmodule Amqpx.Test.Support.Consumer1 do @moduledoc nil @behaviour Amqpx.Gen.Consumer - alias Amqpx.{Basic, Helper} - - @config Application.get_env(:amqpx, __MODULE__) - @queue Application.get_env(:amqpx, __MODULE__)[:queue] + alias Amqpx.Basic + alias Amqpx.Helper def setup(channel) do - Helper.declare(channel, @config) - Basic.consume(channel, @queue, self()) + Helper.declare(channel, Application.fetch_env!(:amqpx, __MODULE__)) + Basic.consume(channel, Application.fetch_env!(:amqpx, __MODULE__)[:queue], self()) {:ok, %{}} end diff --git a/test/support/consumer/consumer_2.ex b/test/support/consumer/consumer_2.ex index ba4a8a9..a462208 100644 --- a/test/support/consumer/consumer_2.ex +++ b/test/support/consumer/consumer_2.ex @@ -2,14 +2,12 @@ defmodule Amqpx.Test.Support.Consumer2 do @moduledoc nil @behaviour Amqpx.Gen.Consumer - alias Amqpx.{Basic, Helper} - - @config Application.get_env(:amqpx, __MODULE__) - @queue Application.get_env(:amqpx, __MODULE__)[:queue] + alias Amqpx.Basic + alias Amqpx.Helper def setup(channel) do - Helper.declare(channel, @config) - Basic.consume(channel, @queue, self()) + Helper.declare(channel, Application.fetch_env!(:amqpx, __MODULE__)) + Basic.consume(channel, Application.fetch_env!(:amqpx, __MODULE__)[:queue], self()) {:ok, %{}} end diff --git a/test/support/consumer/consumer_3.ex b/test/support/consumer/consumer_3.ex index 45b6934..0c76fde 100644 --- a/test/support/consumer/consumer_3.ex +++ b/test/support/consumer/consumer_3.ex @@ -2,14 +2,12 @@ defmodule Amqpx.Test.Support.Consumer3 do @moduledoc nil @behaviour Amqpx.Gen.Consumer - alias Amqpx.{Basic, Helper} - - @config Application.get_env(:amqpx, __MODULE__) - @queue Application.get_env(:amqpx, __MODULE__)[:queue] + alias Amqpx.Basic + alias Amqpx.Helper def setup(channel) do - Helper.declare(channel, @config) - Basic.consume(channel, @queue, self()) + Helper.declare(channel, Application.fetch_env!(:amqpx, __MODULE__)) + Basic.consume(channel, Application.fetch_env!(:amqpx, __MODULE__)[:queue], self()) {:ok, %{}} end diff --git a/test/support/producer/producer_1.ex b/test/support/producer/producer_1.ex index 502a6bf..cbc6fcc 100644 --- a/test/support/producer/producer_1.ex +++ b/test/support/producer/producer_1.ex @@ -1,8 +1,6 @@ defmodule Amqpx.Test.Support.Producer1 do @moduledoc nil - require Logger - alias Amqpx.Gen.Producer @spec send_payload(map) :: :ok | :error diff --git a/test/support/producer/producer_2.ex b/test/support/producer/producer_2.ex index 0f78774..b04531c 100644 --- a/test/support/producer/producer_2.ex +++ b/test/support/producer/producer_2.ex @@ -1,8 +1,6 @@ defmodule Amqpx.Test.Support.Producer2 do @moduledoc nil - require Logger - alias Amqpx.Gen.Producer @spec send_payload(map) :: :ok | :error diff --git a/test/support/producer/producer_3.ex b/test/support/producer/producer_3.ex index 481add3..0ae9474 100644 --- a/test/support/producer/producer_3.ex +++ b/test/support/producer/producer_3.ex @@ -1,8 +1,6 @@ defmodule Amqpx.Test.Support.Producer3 do @moduledoc nil - require Logger - alias Amqpx.Gen.Producer @spec send_payload(map) :: :ok | :error