Class: AWS::SQS::Queue

Inherits:
Object
  • Object
show all
Defined in:
lib/extensions/aws/sqs/queue.rb

Instance Method Summary collapse

Instance Method Details

#consume ⇒ Object 



12
13
14
15
16
17
18
 
# File 'lib/extensions/aws/sqs/queue.rb', line 12

def consume
  message = receive_message
  if message
    message.delete
    ActiveSupport::JSON.decode(message.body)
  end
end

#enqueue(message) ⇒ Object 



8
9
10
 
# File 'lib/extensions/aws/sqs/queue.rb', line 8

def enqueue(message)
  send_message(ActiveSupport::JSON.encode(message))
end

#name ⇒ Object 



4
5
6
 
# File 'lib/extensions/aws/sqs/queue.rb', line 4

def name
  url[/\/([^\/]+)$/, 1]
end

#size ⇒ Object 



20
21
22
 
# File 'lib/extensions/aws/sqs/queue.rb', line 20

def size
  approximate_number_of_messages
end