Contents

require 'bunny'

conn = Bunny.new
conn.start

ch = conn.create_channel
q  = ch.queue('wallet_events', durable: true)

10.times do |index|
  msg = "Hello World! #{index}"
  q.publish(msg)
  puts " [x] Sent #{msg}"
end

conn.close

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
asynk-0.0.2	publisher.rb
asynk-0.0.1	publisher.rb