Sha256: c233aa9bb352d2b543ee7fb016cccc9329d9b1da4b847003f5f2322a579c8277
Contents?: true
Size: 448 Bytes
Versions: 54
Compression:
Stored size: 448 Bytes
Contents
#!/usr/bin/env ruby # encoding: utf-8 require "rubygems" require "amqp" # Declaring a temporary exclusive queue AMQP.start("amqp://guest:guest@dev.rabbitmq.com") do |connection, open_ok| AMQP::Channel.new do |channel, open_ok| channel.queue("", :auto_delete => true, :exclusive => true) do |queue, declare_ok| puts "#{queue.name} is ready to go." connection.close { EventMachine.stop { exit } } end end end
Version data entries
54 entries across 54 versions & 1 rubygems