Contents

require 'bunny'
require 'json'

STDOUT.sync = true

class Receiver
  def initialize(config)
    @connection = Bunny.new("amqp://#{config[:bunny_username]}:#{config[:bunny_password]}@#{config[:bunny_host]}").start
    @channel = @connection.create_channel
    @exchange = @channel.fanout('lighting.messages')
  end

  def listen(queue_name, &block)
    puts 'listening for light messages...'
    @channel.queue(queue_name, :auto_delete => true).bind(@exchange).subscribe(:block => true) do |delivery_info, metadata, payload|
      yield JSON.parse(payload)
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
test_driven_lighting-1.2.0	lib/test_driven_lighting/receiver.rb
test_driven_lighting-1.1.0	lib/test_driven_lighting/receiver.rb