Class: Hushed::Queue

Inherits:
Object
  • Object
show all
Defined in:
lib/hushed/queue.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(client) ⇒ Queue

Returns a new instance of Queue.



4
5
6
 
# File 'lib/hushed/queue.rb', line 4

def initialize(client)
  @client = client
end

Instance Attribute Details

#client ⇒ Object (readonly)

Returns the value of attribute client.



3
4
5
 
# File 'lib/hushed/queue.rb', line 3

def client
  @client
end

Instance Method Details

#approximate_pending_messages ⇒ Object 



23
24
25
 
# File 'lib/hushed/queue.rb', line 23

def approximate_pending_messages
  client.from_quiet_queue.approximate_number_of_messages
end

#receive ⇒ Object 



13
14
15
16
17
18
19
20
21
 
# File 'lib/hushed/queue.rb', line 13

def receive
  queue = client.from_quiet_queue
  message = nil
  queue.receive_message do |msg|
    message = Message.new(xml: msg.body)
    message.message_object = msg
  end
  message || Message.new
end

#send(message) ⇒ Object 



8
9
10
11
 
# File 'lib/hushed/queue.rb', line 8

def send(message)
  queue = client.to_quiet_queue
  queue.send_message(message.to_xml)
end