Parent

Qrack::Queue

Queue ancestor class

Attributes

client[R]
default_consumer[RW]

@return [AMQ::Client::Consumer] Default consumer (registered with {Queue#subscribe}).

delivery_tag[RW]
name[R]

Public Instance Methods

consumer_count() click to toggle source

Returns consumer count from {Queue#status}.

# File lib/qrack/queue.rb, line 16
def consumer_count
  s = status
  s[:consumer_count]
end
message_count() click to toggle source

Returns message count from {Queue#status}.

# File lib/qrack/queue.rb, line 22
def message_count
  s = status
  s[:message_count]
end
publish(data, opts = {}) click to toggle source

@return [NilClass] nil @deprecated @note This method will be removed before 0.8 release.

# File lib/qrack/queue.rb, line 32
def publish(data, opts = {})
  Bunny.deprecation_warning("Qrack::Queue#publish", "0.8", "Use direct_exchange = bunny.exchange(''); direct_exchange.publish('message', key: queue.name) if you want to publish directly to one given queue. For more informations see https://github.com/ruby-amqp/bunny/issues/15 and for more theoretical explanation check http://bit.ly/nOF1CK")
  exchange.publish(data, opts)
end

[Validate]

Generated with the Darkfish Rdoc Generator 2.