Class: Queuel::IronMq::Queue

Inherits:

Base::Queue

• Object
• Base::Queue
• Queuel::IronMq::Queue

Extended by:

Forwardable

Defined in:

lib/queuel/iron_mq/queue.rb

Instance Method Summary

• #peek(options = {}) ⇒ Object
• #push(message, options = {}) ⇒ Object

  For IronMQ it should just be (message).

• #size ⇒ Object

Methods inherited from Base::Queue

#initialize, #max_pool_tasks, #pop, #receive

Methods included from Queuel::Introspect

#const_with_nesting, #module_names

Constructor Details

This class inherits a constructor from Queuel::Base::Queue

Instance Method Details

#peek(options = {}) ⇒ Object

# File 'lib/queuel/iron_mq/queue.rb', line 11

def peek(options = {})
  Array(queue_connection.peek(options))
end

#push(message, options = {}) ⇒ Object

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 ⇒ Object

# File 'lib/queuel/iron_mq/queue.rb', line 20

def size
  queue_connection.size
end