Sha256: 6bffb9cadcfa5bf17ff1700cd671c81eee4409bc80565ed8e2e45e396e0d9526
Contents?: true
Size: 1.08 KB
Versions: 68
Compression:
Stored size: 1.08 KB
Contents
#!/usr/bin/env ruby
# encoding: utf-8
__dir = File.dirname(File.expand_path(__FILE__))
require File.join(__dir, "example_helper")
amq_client_example "Purge a queue and announce how many messages it had" do |client|
channel = AMQ::Client::Channel.new(client, 1)
channel.open do
puts "Channel #{channel.id} is now open!"
4.times do
q = AMQ::Client::Queue.new(client, channel, AMQ::Protocol::EMPTY_STRING)
q.declare(false, false, false, true)
end
begin
q = AMQ::Client::Queue.new(client, channel, AMQ::Protocol::EMPTY_STRING)
q.declare(false, false, false, true, true)
rescue ArgumentError => e
puts "Non-sensical declaration of a server-named queue with nowait did not slip through, great"
end
queue = AMQ::Client::Queue.new(client, channel, AMQ::Protocol::EMPTY_STRING)
queue.declare(false, false, false, true) do
puts "Queue #{queue.name.inspect} is now declared!"
puts "Channel is aware of the following queues: #{channel.queues.map { |q| q.name }.join(', ')}"
client.disconnect { EM.stop }
end
end
end
Version data entries
68 entries across 68 versions & 1 rubygems