lib/alephant/publisher/queue.rb in alephant-publisher-queue-2.1.4 vs lib/alephant/publisher/queue.rb in alephant-publisher-queue-2.2.0

- old
+ new

@@ -30,11 +30,11 @@ @queue = SQSHelper::Queue.new( aws_queue, archiver, opts.queue[:visibility_timeout] || VISIBILITY_TIMEOUT, - opts.queue[:receive_wait_time] || RECEIVE_WAIT_TIME, + opts.queue[:receive_wait_time] || RECEIVE_WAIT_TIME ) end def run! loop { processor.consume(@queue.message) } @@ -56,10 +56,10 @@ options[key] = opts.queue[key] == "true" if whitelist_key(opts.queue, key) end end def whitelist_key(options, key) - options.has_key?(key) && key != :log_validator + options.key?(key) && key != :log_validator end def archive_cache Cache.new( opts.writer[:s3_bucket_id],