Missing test helper to lookup queues

This commit is contained in:
Daniil Fedotov 2018-03-07 15:26:46 +00:00
parent 14c4ab7753
commit 8840460e00
1 changed files with 7 additions and 0 deletions

View File

@ -162,6 +162,13 @@ defmodule TestHelper do
[queue_name, false, false, "acting-user"])
end
def lookup_queue(name, vhost) do
queue_name = :rabbit_misc.r(vhost, :queue, name)
:rpc.call(get_rabbit_hostname(),
:rabbit_amqqueue, :lookup,
[queue_name])
end
def declare_exchange(name, vhost, type \\ :direct, durable \\ false, auto_delete \\ false, internal \\ false, args \\ []) do
exchange_name = :rabbit_misc.r(vhost, :exchange, name)
:rpc.call(get_rabbit_hostname(),