class Promiscuous::Subscriber::UnitOfWork
Public Instance Methods
on_message()
click to toggle source
# File lib/promiscuous_black_hole/unit_of_work.rb, line 11 def on_message operations.each { |op| Promiscuous::BlackHole::Operation.process(op) } message.ack end
operations()
click to toggle source
# File lib/promiscuous_black_hole/unit_of_work.rb, line 5 def operations message.parsed_payload['operations'].map do |op| Promiscuous::BlackHole::Message.new(op) end end