Move queue utilities to a dedicated module (#124)

This functionality might also have value for consumers and other use cases, so let's not lock it for publishers only.
meltwater · Oct 31, 2019 · 89febcf · 89febcf
1 parent 86c1ecc
commit 89febcf
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 1 deletion.
diff --git a/lib/publisher.ex b/lib/publisher.ex
@@ -8,7 +8,7 @@ defmodule GenRMQ.Publisher do
 
   require Logger
 
-  alias AMQP.Queue
+  alias GenRMQ.Queue
 
   # list of fields permitted in message metadata at top level
   @metadata_fields ~w(

diff --git a/lib/queue.ex b/lib/queue.ex
@@ -0,0 +1,11 @@
+defmodule GenRMQ.Queue do
+  @moduledoc """
+  This module defines utility functions for queues
+  """
+
+  defdelegate consumer_count(channel, queue), to: AMQP.Queue
+  defdelegate empty?(channel, queue), to: AMQP.Queue
+  defdelegate message_count(channel, queue), to: AMQP.Queue
+  defdelegate purge(channel, queue), to: AMQP.Queue
+  defdelegate status(channel, queue), to: AMQP.Queue
+end