Module: Alephant::Publisher::Queue

Defined in:

lib/alephant/publisher/queue.rb,
lib/alephant/publisher/queue/writer.rb,
lib/alephant/publisher/queue/options.rb,
lib/alephant/publisher/queue/version.rb,
lib/alephant/publisher/queue/processor.rb,
lib/alephant/publisher/queue/processor/base.rb,
lib/alephant/publisher/queue/sqs_helper/queue.rb,
lib/alephant/publisher/queue/sqs_helper/archiver.rb

Defined Under Namespace

Modules: SQSHelper Classes: BaseProcessor, InvalidKeySpecifiedError, Options, Processor, Publisher, Writer

Constant Summary

VERSION =

"2.0.2"

Class Method Summary

• .create(opts = {}, processor = nil) ⇒ Object

Class Method Details

.create(opts = {}, processor = nil) ⇒ Object

# File 'lib/alephant/publisher/queue.rb', line 14

def self.create(opts = {}, processor = nil)
  processor ||= Processor.new(opts.writer)
  Publisher.new(opts, processor)
end