Sha256: bc96d6e77917277582cbd7a8e84419a7d7e7bcf67b85e15acec363932c7aac70
Contents?: true
Size: 794 Bytes
Versions: 16
Compression:
Stored size: 794 Bytes
Contents
# encoding: utf-8
module HotBunnies
module Channel
def queue(name, options={})
Queue.new(self, name, options)
end
def exchange(name, options={})
exchange = Exchange.new(self, name, options)
exchange.declare!
exchange
end
def default_exchange
self.exchange("", :durable => true, :auto_delete => false, :type => "direct")
end
def qos(options={})
if options.size == 1 && options[:prefetch_count]
then basic_qos(options[:prefetch_count])
else basic_qos(options.fetch(:prefetch_size, 0), options.fetch(:prefetch_count, 0), options.fetch(:global, false))
end
end
def prefetch=(n)
qos(:prefetch_count => n)
end
def on_return(&block)
self.set_return_listener(block)
end
end
end
Version data entries
16 entries across 16 versions & 1 rubygems