Contents

#!/usr/bin/env ruby
# encoding: utf-8

require "bundler"
Bundler.setup

$:.unshift(File.expand_path("../../../lib", __FILE__))

require 'amqp'

if RUBY_VERSION == "1.8.7"
  class Array
    alias sample choice
  end
end

puts "=> Handling message returns"
puts

AMQP.start(:host => '127.0.0.1') do |connection|
  channel  = AMQP.channel
  channel.on_error { EM.stop; raise 'channel error' }

  exchange = channel.fanout("amq.fanout")
  exchange.on_return do |basic_return, header, payload|
    puts "#{payload} was returned! reply_code = #{basic_return.reply_code}, reply_text = #{basic_return.reply_text}"
  end

  EventMachine.add_timer(0.3) {
    10.times do |i|
      exchange.publish("Message ##{i}", :immediate => true)
    end    
  }

  EventMachine.add_timer(2) {
    connection.close {
      EventMachine.stop
    }
  }
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
amqp-0.8.0.rc12	examples/publishing/returned_messages.rb
amqp-0.8.0.rc11	examples/publishing/returned_messages.rb