Class: Emque::Producing::ChangesPayloadGenerator

Inherits:
Object
  • Object
show all
Defined in:
lib/emque/producing/message/message_with_changeset.rb

Instance Method Summary collapse

Constructor Details

#initialize(changeset_data = {}) ⇒ ChangesPayloadGenerator

Returns a new instance of ChangesPayloadGenerator.



46
47
48
49
50
 
# File 'lib/emque/producing/message/message_with_changeset.rb', line 46

def initialize(changeset_data = {})
  @original = changeset_data[:original] || {}
  @updated = changeset_data[:updated] || {}
  @translated_attrs = changeset_data[:translated_attrs] || {}
end

Instance Method Details

#execute ⇒ Object 



52
53
54
55
 
# File 'lib/emque/producing/message/message_with_changeset.rb', line 52

def execute
  translate_attrs if translated_attrs.any?
  {:original => original, :updated => updated, :delta => delta}
end