Contents

require 'bunny_carrot'
require 'logger'
require "stringio"

logger = Logger.new(StringIO.new)
BunnyCarrot.logger = logger

ENV["RABBITMQ_URL"] = "amqp://127.0.0.1:5672"

QUEUE_NAME, MESSAGE = *ARGV

BunnyCarrot::RabbitHole.publish queue_name: QUEUE_NAME, payload: { message: MESSAGE }
sleep 1

class BusinessWorker < BunnyCarrot::BaseWorker
  def perform(payload, headers)
    print payload['message']
  end
end

begin
  Timeout.timeout(5) do
    BunnyCarrot::Consumer.subscribe(QUEUE_NAME, BusinessWorker.new, block: true)
  end
rescue Timeout::Error
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
bunny_carrot-0.0.2	spec/fixtures/producer_and_consumer.rb