Class Qrack::Queue
In: lib/qrack/queue.rb
Parent: Object
Timeout::Error ClientTimeout ConnectionTimeout StandardError InvalidTypeError\n[lib/qrack/qrack08.rb\nlib/qrack/qrack09.rb] BufferOverflowError\n[lib/qrack/qrack08.rb\nlib/qrack/qrack09.rb] Channel Client Subscription Queue Protocol09 Transport09 Protocol Transport lib/qrack/qrack08.rb lib/qrack/channel.rb lib/qrack/client.rb lib/qrack/subscription.rb lib/qrack/queue.rb Transport Transport09 Protocol Protocol09 Qrack dot/m_23_0.png

Queue ancestor class

Methods

consumer_count   message_count   publish  

Attributes

client  [R] 
delivery_tag  [RW] 
name  [R] 
subscription  [RW] 

Public Instance methods

consumer_count()

DESCRIPTION:

Returns consumer count from Queue#status.

[Source]

    # File lib/qrack/queue.rb, line 17
17:           def consumer_count
18:             s = status
19:                         s[:consumer_count]
20:           end
message_count()

DESCRIPTION:

Returns message count from Queue#status.

[Source]

    # File lib/qrack/queue.rb, line 30
30:           def message_count
31:             s = status
32:                         s[:message_count]
33:           end
publish(data, opts = {})

DESCRIPTION:

Publishes a message to the queue via the default nameless ’’ direct exchange.

RETURNS:

nil

[Source]

    # File lib/qrack/queue.rb, line 47
47:           def publish(data, opts = {})
48:             exchange.publish(data, opts)
49:           end

[Validate]