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