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