Object
Queue ancestor class
Returns consumer count from Queue#status.
# File lib/qrack/queue.rb, line 17 def consumer_count s = status s[:consumer_count] end
Returns message count from Queue#status.
# File lib/qrack/queue.rb, line 30 def message_count s = status s[:message_count] end
Publishes a message to the queue via the default nameless ” direct exchange.
nil
# File lib/qrack/queue.rb, line 47 def publish(data, opts = {}) exchange.publish(data, opts) end
[Validate]
Generated with the Darkfish Rdoc Generator 2.