class Alephant::Publisher::Queue::Processor

Attributes

opts[R]

Public Class Methods

new(opts = nil) click to toggle source
# File lib/alephant/publisher/queue/processor.rb, line 9
def initialize(opts = nil)
  @opts = opts
end

Public Instance Methods

consume(message_collection) click to toggle source
# File lib/alephant/publisher/queue/processor.rb, line 13
def consume(message_collection)
  return unless message_collection && message_collection.size > 0

  message = message_collection.first
  write(message)
  message.delete
end

Private Instance Methods

write(msg) click to toggle source
# File lib/alephant/publisher/queue/processor.rb, line 27
def write(msg)
  Writer.new(writer_config, msg).run!
end
writer_config() click to toggle source
# File lib/alephant/publisher/queue/processor.rb, line 23
def writer_config
  opts ? opts.writer : {}
end