Class: Emque::Producing::ChangesPayloadGenerator

Inherits:

Object

• Object
• Emque::Producing::ChangesPayloadGenerator

Defined in:

lib/emque/producing/message/message_with_changeset.rb

Instance Method Summary

• #execute ⇒ Object
• #initialize(opts = {}) ⇒ ChangesPayloadGenerator constructor

  A new instance of ChangesPayloadGenerator.

Constructor Details

#initialize(opts = {}) ⇒ ChangesPayloadGenerator

# File 'lib/emque/producing/message/message_with_changeset.rb', line 30

def initialize(opts = {})
  @original = opts.fetch(:original, {}) || {}
  @updated = opts.fetch(:updated, {}) || {}
end

Instance Method Details

#execute ⇒ Object

# File 'lib/emque/producing/message/message_with_changeset.rb', line 35

def execute
  {:original => original, :updated => updated, :delta => delta}
end