lib/queuel/iron_mq/queue.rb in queuel-0.1.0 vs lib/queuel/iron_mq/queue.rb in queuel-0.2.0
- old
+ new
@@ -10,11 +10,11 @@
def peek(options = {})
Array(queue_connection.peek(options))
end
# For IronMQ it should just be (message)
- def push(message)
- queue_connection.post message
+ def push(message, options = {})
+ queue_connection.post build_push_message(message, options)
end
private
def pop_bare_message(options = {})
queue_connection.get options