lib/queuel/iron_mq/queue.rb in queuel-0.3.1 vs lib/queuel/iron_mq/queue.rb in queuel-0.4.0
- old
+ new
@@ -15,9 +15,13 @@
# For IronMQ it should just be (message)
def push(message, options = {})
queue_connection.post build_push_message(message, options)
end
+ def size
+ queue_connection.size
+ end
+
private
def pop_bare_message(options = {})
queue_connection.get options.merge(default_get_message_options)
end