Module: TxghQueue::Backends::Sqs

Defined in:: lib/txgh-queue/backends/sqs.rb,
lib/txgh-queue/backends/sqs/job.rb,
lib/txgh-queue/backends/sqs/queue.rb,
lib/txgh-queue/backends/sqs/config.rb,
lib/txgh-queue/backends/sqs/consumer.rb,
lib/txgh-queue/backends/sqs/producer.rb,
lib/txgh-queue/backends/sqs/retry_logic.rb,
lib/txgh-queue/backends/sqs/history_sequence.rb,
lib/txgh-queue/backends/sqs/message_attributes.rb

Defined Under Namespace

Classes: Config, Consumer, HistorySequence, Job, MessageAttributes, Producer, Queue, RetriesExceededError, RetryLogic

Class Method Summary collapse

Class Method Details

.consumer_for(events, logger = Txgh::TxLogger.logger) ⇒ `Object`



20
21
22

# File 'lib/txgh-queue/backends/sqs.rb', line 20

def consumer_for(events, logger = Txgh::TxLogger.logger)
  Consumer.new(find_queues_for(Array(events)), logger)
end

.producer_for(events, logger = Txgh::TxLogger.logger) ⇒ `Object`



16
17
18

# File 'lib/txgh-queue/backends/sqs.rb', line 16

def producer_for(events, logger = Txgh::TxLogger.logger)
  Producer.new(find_queues_for(Array(events)), logger)
end