Contents

#!/usr/bin/env ruby

ENV['RABBIT_URL'] = 'amqp://guest:guest@localhost:5672'
ENV['RABBIT_EVENT_BUS_APP_NAME'] = 'EventBusExampleApp'
ENV['RABBIT_EVENT_BUS_VHOST'] = 'event_bus'
ENV['RABBIT_EVENT_BUS_TOPIC_NAME'] = 'event_bus'

$LOAD_PATH.unshift File.expand_path('../../lib', __FILE__)

require 'rubygems'
require 'bundler'
Bundler.require(:default, 'development')

require 'event_bus'


class CustomEventListener < EventBus::Listeners::Base
  bind :pay, 'resource.custom.pay'
  bind :receive, 'resource.custom.receive'

  def pay(event, delivery_info)
    puts "Paid #{event.body['amount']} for #{event.body['name']} ~> #{event.name}"

    channel.acknowledge(delivery_info.delivery_tag, false)
  end

  def receive(event, delivery_info)
    if event.body['amount'] > 42
      channel.acknowledge(delivery_info.delivery_tag, false)
      puts "Received #{event.body['amount']} from #{event.body['name']} ~> #{event.name}"
    else
      puts "[consumer] Got SKIPPED message"
    end
  end
end

puts "****************** Daemon Ready ******************"

EventBus::Daemon.start

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
event_bus_rb-2.1.0	examples/daemon.rb
event_bus_rb-2.0.3	examples/daemon.rb
event_bus_rb-2.0.2	examples/daemon.rb
event_bus_rb-2.0.1	examples/daemon.rb
event_bus_rb-2.0.0	examples/daemon.rb