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'


event_name = 'resource.origin.action'

puts 'Start receiving messages'

EventBus::Listener.on(event_name) do |event, _delivery_info|
  puts ""
  puts "  - Received a message from #{event.name}:"
  puts "     Message: #{event.body}"
  puts ""
end

puts  'Stop receiving messages'

EventBus::Config.broker.close_connection

Version data entries

5 entries across 5 versions & 1 rubygems

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