class Synapse::Serialization::SerializedDomainEventMessage

Serialized representation of a domain event message

Attributes

aggregate_id[R]

@return [Object]

sequence_number[R]

@return [Integer]

Public Class Methods

builder() click to toggle source

@return [Class]

# File lib/synapse/serialization/message/serialized_message.rb, line 164
def self.builder
  SerializedDomainEventMessageBuilder
end
new(id, metadata, payload, timestamp, aggregate_id, sequence_number) click to toggle source

@param [String] id @param [LazyObject] metadata @param [LazyObject] payload @param [Time] timestamp @param [Object] aggregate_id @param [Integer] sequence_number @return [undefined]

# File lib/synapse/serialization/message/serialized_message.rb, line 156
def initialize(id, metadata, payload, timestamp, aggregate_id, sequence_number)
  super id, metadata, payload, timestamp

  @aggregate_id = aggregate_id
  @sequence_number = sequence_number
end

Protected Instance Methods

build_duplicate(builder, metadata) click to toggle source

@param [SerializedDomainEventMessageBuilder] builder @param [Hash] metadata @return [undefined]

# File lib/synapse/serialization/message/serialized_message.rb, line 173
def build_duplicate(builder, metadata)
  super
  builder.aggregate_id = @aggregate_id
  builder.sequence_number = @sequence_number
end