switch to Tackle.Connection.open

renderedtext · Nov 23, 2023 · fa367d6 · fa367d6
1 parent 5f129c6
commit fa367d6
Show file tree

Hide file tree

Showing 4 changed files with 5 additions and 5 deletions.
diff --git a/lib/tackle.ex b/lib/tackle.ex
@@ -25,7 +25,7 @@ defmodule Tackle do
       |> Tackle.Util.parse_exchange()
 
     Logger.debug("Connecting to '#{Tackle.Util.scrub_url(url)}'")
-    {:ok, connection} = AMQP.Connection.open(url)
+    {:ok, connection} = Tackle.Connection.open(url)
     channel = Tackle.Channel.create(connection)
 
     try do

diff --git a/lib/tackle/connection.ex b/lib/tackle/connection.ex
@@ -31,6 +31,8 @@ defmodule Tackle.Connection do
     open_(name, url)
   end
 
+  def open(url), do: AMQP.Connection.open(url)
+
   @doc """
   Get a list of opened connections
   """
@@ -101,6 +103,4 @@ defmodule Tackle.Connection do
   defp validate_connection_process_rh(_alive? = false, _connection, _name) do
     {:error, :no_process}
   end
-
-  def open(url), do: AMQP.Connection.open(url)
 end
diff --git a/lib/tackle/delayed_retry.ex b/lib/tackle/delayed_retry.ex
@@ -10,7 +10,7 @@ defmodule Tackle.DelayedRetry do
   def publish(url, queue, payload, options) do
     Logger.debug("Connecting to '#{Tackle.Util.scrub_url(url)}'")
 
-    {:ok, connection} = AMQP.Connection.open(url)
+    {:ok, connection} = Tackle.Connection.open(url)
     {:ok, channel} = Channel.open(connection)
 
     try do

diff --git a/lib/tackle/republisher.ex b/lib/tackle/republisher.ex
@@ -5,7 +5,7 @@ defmodule Tackle.Republisher do
   def republish(url, queue, exchange, routing_key, count) do
     Logger.debug("Connecting to '#{Tackle.Util.scrub_url(url)}'")
 
-    {:ok, connection} = AMQP.Connection.open(url)
+    {:ok, connection} = Tackle.Connection.open(url)
     channel = Tackle.Channel.create(connection)
 
     try do