module Traffiq::TestHelpers
Public Instance Methods
last_amqp_queue_message(queue)
click to toggle source
# File lib/traffiq/test_helpers.rb, line 11 def last_amqp_queue_message(queue) _, _, payload = queue.pop if payload payload = JSON.parse(payload) end payload end
setup_amqp_queue(url, exchange_name, routing_key)
click to toggle source
# File lib/traffiq/test_helpers.rb, line 3 def setup_amqp_queue(url, exchange_name, routing_key) amqp = Traffiq::AMQP.new(url) amqp.define_exchange(exchange_name) queue = amqp.bind_queue(routing_key) queue.purge return queue, amqp end