Sha256: 7374f2cf5d1561219f41e6d2131df65cf27263439357450483d55f6bacfffb97
Contents?: true
Size: 551 Bytes
Versions: 23
Compression:
Stored size: 551 Bytes
Contents
module Refinery #:nodoc:
# Mix this module in to classes that want to access a queue.
module Queueable
# Get a named queue
def queue(name)
queue_provider.queue(name)
end
protected
# Get the queue provider. Defaults to RightAws::SqsGen2 running
# in multi-thread mode.
def queue_provider
@queue_provider ||= RightAws::SqsGen2.new(
config['aws']['credentials']["access_key_id"],
config['aws']['credentials']["secret_access_key"],
{:multi_thread => true}
)
end
end
end
Version data entries
23 entries across 23 versions & 2 rubygems