Sha256: f92e8ed20f9b7bbe2a50c111f1937c90cf98b9530206d0017bb26770ee8b0c50
Contents?: true
Size: 412 Bytes
Versions: 113
Compression:
Stored size: 412 Bytes
Contents
#!/usr/bin/env ruby
require 'bunny'
Bundler.setup
begin
connection = Bunny.new(:automatically_recover => false)
connection.start
ch = connection.channel
x = ch.default_exchange
loop do
10.times do |i|
print "."
x.publish("")
end
sleep 3.0
end
rescue Bunny::NetworkFailure => e
ch.maybe_kill_consumer_work_pool!
sleep 10
puts "Recovering manually..."
retry
end
Version data entries
113 entries across 113 versions & 1 rubygems