Sha256: 1ed80ba84c06617a6ee550e3ea84b961e6aeb8f2e8230363b30cf87f30ad39f5
Contents?: true
Size: 443 Bytes
Versions: 1
Compression:
Stored size: 443 Bytes
Contents
#!/usr/bin/env ruby # encoding: utf-8 require "rubygems" require "amqp" # Declaring a durable shared queue AMQP.start("amqp://guest:guest@dev.rabbitmq.com") do |connection, open_ok| AMQP::Channel.new do |channel, open_ok| AMQP::Queue.new(channel, "images.resize", :durable => true) do |queue, declare_ok| puts "#{queue.name} is ready to go." connection.close { EventMachine.stop { exit } } end end end
Version data entries
1 entries across 1 versions & 1 rubygems
Version | Path |
---|---|
amqp-0.8.0.rc13 | examples/guides/queues/02a_declaring_a_durable_shared_queue.rb |