Sha256: 537c8bfd37c695b583fa8fb70a56b91ce3b2ddcc1b1960c3f7ef4a7d30dd8f1d
Contents?: true
Size: 418 Bytes
Versions: 10
Compression:
Stored size: 418 Bytes
Contents
module Queuel
module SQS
class Poller < Base::Poller
# Public: poll
private
def built_options
options.merge default_options # intentional direction, force defaults
end
def default_options
{ n: 1 }
end
def peek_options
{ n: self.workers }
end
def queue_size
queue.approximate_number_of_messages
end
end
end
end
Version data entries
10 entries across 10 versions & 1 rubygems