module Messaging::Controls::Metadata

Constants

Empty

Public Class Methods

causation_message_global_position() click to toggle source
# File lib/messaging/controls/metadata.rb, line 33
def self.causation_message_global_position
  111
end
causation_message_identifier() click to toggle source
# File lib/messaging/controls/metadata.rb, line 53
def self.causation_message_identifier
  "#{causation_message_stream_name}/#{causation_message_position}"
end
causation_message_position() click to toggle source
# File lib/messaging/controls/metadata.rb, line 29
def self.causation_message_position
  11
end
causation_message_stream_name() click to toggle source
# File lib/messaging/controls/metadata.rb, line 25
def self.causation_message_stream_name
  "someCausation"
end
correlation_stream_name() click to toggle source
# File lib/messaging/controls/metadata.rb, line 37
def self.correlation_stream_name
  "someCorrelation"
end
data() click to toggle source
# File lib/messaging/controls/metadata.rb, line 73
def self.data
  {
    stream_name: stream_name,
    position: position,
    global_position: global_position,

    causation_message_stream_name: causation_message_stream_name,
    causation_message_position: causation_message_position,
    causation_message_global_position: causation_message_global_position,

    correlation_stream_name: correlation_stream_name,

    reply_stream_name: reply_stream_name,

    properties: Properties.example,
    local_properties: LocalProperties.example,

    time: time,

    schema_version: schema_version
  }
end
example() click to toggle source
# File lib/messaging/controls/metadata.rb, line 4
def self.example
  data = self.data

  data[:properties] = properties
  data[:local_properties] = local_properties

  Messaging::Message::Metadata.build(data)
end
global_position() click to toggle source
# File lib/messaging/controls/metadata.rb, line 21
def self.global_position
  222
end
identifier() click to toggle source
# File lib/messaging/controls/metadata.rb, line 49
def self.identifier
  "#{stream_name}/#{position}"
end
local_properties() click to toggle source
# File lib/messaging/controls/metadata.rb, line 69
def self.local_properties
  LocalProperties.example
end
position() click to toggle source
# File lib/messaging/controls/metadata.rb, line 17
def self.position
  1
end
properties() click to toggle source
# File lib/messaging/controls/metadata.rb, line 57
def self.properties
  Properties.example
end
reply_stream_name() click to toggle source
# File lib/messaging/controls/metadata.rb, line 41
def self.reply_stream_name
  "someReply"
end
schema_version() click to toggle source
# File lib/messaging/controls/metadata.rb, line 45
def self.schema_version
  '1.1'
end
stream_name() click to toggle source
# File lib/messaging/controls/metadata.rb, line 13
def self.stream_name
  'someSource'
end
time() click to toggle source
# File lib/messaging/controls/metadata.rb, line 61
def self.time
  Time::Raw.example
end