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