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