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