Sha256: fd34a35fbc507b780ac0f57cbe4b008144e29d4f55bf17c89c9692c43f99ffc0

Contents?: true

Size: 467 Bytes

Versions: 54

Compression:

Stored size: 467 Bytes

Contents

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

require "bundler"
Bundler.setup

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

require 'amqp'

puts "Running amqp gem #{AMQP::VERSION}"

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

54 entries across 54 versions & 1 rubygems

Version Path
amqp-1.8.0 examples/issues/issue_75.rb
amqp-1.7.0 examples/issues/issue_75.rb
amqp-1.6.0 examples/issues/issue_75.rb
amqp-1.5.3 examples/issues/issue_75.rb
amqp-1.5.2 examples/issues/issue_75.rb
amqp-1.5.1 examples/issues/issue_75.rb
amqp-1.5.0 examples/issues/issue_75.rb
amqp-1.4.2 examples/issues/issue_75.rb
amqp-1.4.1 examples/issues/issue_75.rb
amqp-1.4.0 examples/issues/issue_75.rb
amqp-1.3.0 examples/issues/issue_75.rb
amqp-1.2.1 examples/issues/issue_75.rb
amqp-1.2.0 examples/issues/issue_75.rb
amqp-1.1.8 examples/issues/issue_75.rb
amqp-1.1.7 examples/issues/issue_75.rb
amqp-1.1.6 examples/issues/issue_75.rb
amqp-1.1.5 examples/issues/issue_75.rb
amqp-1.1.4 examples/issues/issue_75.rb
amqp-1.1.3 examples/issues/issue_75.rb
amqp-1.0.4 examples/issues/issue_75.rb