class Queuel::IronMq::Queue
Public Instance Methods
peek(options = {})
click to toggle source
# File lib/queuel/iron_mq/queue.rb, line 11 def peek(options = {}) Array(queue_connection.peek(options)) end
push(message, options = {})
click to toggle source
For IronMQ it should just be (message)
# File lib/queuel/iron_mq/queue.rb, line 16 def push(message, options = {}) queue_connection.post build_push_message(message, options) end
size()
click to toggle source
# File lib/queuel/iron_mq/queue.rb, line 20 def size queue_connection.size end
Private Instance Methods
default_get_message_options()
click to toggle source
# File lib/queuel/iron_mq/queue.rb, line 33 def default_get_message_options { c: SecureRandom.hex } end
pop_bare_message(options = {})
click to toggle source
# File lib/queuel/iron_mq/queue.rb, line 25 def pop_bare_message(options = {}) queue_connection.get options.merge(default_get_message_options) end
queue_connection()
click to toggle source
# File lib/queuel/iron_mq/queue.rb, line 29 def queue_connection @queue_connection ||= client.queue(name) end