Contents

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

require "bundler"
Bundler.setup

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

require 'amqp'

AMQP.start(:host => "localhost") do |connection|
  channel  = AMQP::Channel.new(connection)
  channel.fanout("logs.nad", :auto_delete => false)
  channel.fanout("logs.ad",  :auto_delete => true)

  EM.add_timer(1) do
    connection.close do
      EM.stop { exit }
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
amqp-0.7.5	examples/issues/issue_75.rb
amqp-0.7.4	examples/issues/issue_75.rb
amqp-0.7.3	examples/issues/issue_75.rb
amqp-0.7.2	examples/issues/issue_75.rb