lib/propono/components/client.rb in propono-2.0.0 vs lib/propono/components/client.rb in propono-2.1.0
- old
+ new
@@ -67,11 +67,11 @@
# one does not exist, so there is no need to call
# <tt>subscribe</tt> in addition.
#
# @param [String] topic The topic to subscribe to.
# @param &message_processor The block to yield for each message.
- def listen(topic_name, &message_processor)
- QueueListener.listen(aws_client, config, topic_name, &message_processor)
+ def listen(topic_name, options = {}, &message_processor)
+ QueueListener.listen(aws_client, config, topic_name, options, &message_processor)
end
# Listens on a queue and yields for each message
#
# Calling this will enter a queue-listening loop that