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],