module Messaging::Fixtures::Controls::Metadata

Public Class Methods

causation_message_global_position() click to toggle source
# File lib/messaging/fixtures/controls/metadata.rb, line 50
def self.causation_message_global_position
  Message::Metadata.global_position
end
causation_message_position() click to toggle source
# File lib/messaging/fixtures/controls/metadata.rb, line 46
def self.causation_message_position
  Message::Metadata.position
end
causation_message_stream_name() click to toggle source
# File lib/messaging/fixtures/controls/metadata.rb, line 42
def self.causation_message_stream_name
  Message::Metadata.stream_name
end
correlation_stream_name() click to toggle source
# File lib/messaging/fixtures/controls/metadata.rb, line 54
def self.correlation_stream_name
  'someCorrelationStream'
end
example() click to toggle source
# File lib/messaging/fixtures/controls/metadata.rb, line 5
def self.example
  metadata = Messaging::Message::Metadata.new

  metadata.stream_name = stream_name
  metadata.position = position
  metadata.global_position = global_position

  metadata.causation_message_stream_name = causation_message_stream_name
  metadata.causation_message_position = causation_message_position
  metadata.causation_message_global_position = causation_message_global_position

  metadata.correlation_stream_name = correlation_stream_name

  metadata.reply_stream_name = reply_stream_name

  metadata.properties = properties
  metadata.local_properties = local_properties

  metadata.time = time

  metadata.schema_version = schema_version

  metadata
end
global_position() click to toggle source
# File lib/messaging/fixtures/controls/metadata.rb, line 38
def self.global_position
  111
end
local_properties() click to toggle source
# File lib/messaging/fixtures/controls/metadata.rb, line 68
def self.local_properties
  {
    some_local_property: 'some local property value'
  }
end
position() click to toggle source
# File lib/messaging/fixtures/controls/metadata.rb, line 34
def self.position
  1
end
properties() click to toggle source
# File lib/messaging/fixtures/controls/metadata.rb, line 62
def self.properties
  {
    some_property: 'some property value'
  }
end
reply_stream_name() click to toggle source
# File lib/messaging/fixtures/controls/metadata.rb, line 58
def self.reply_stream_name
  'someReplyStream'
end
schema_version() click to toggle source
# File lib/messaging/fixtures/controls/metadata.rb, line 78
def self.schema_version
  '1'
end
stream_name() click to toggle source
# File lib/messaging/fixtures/controls/metadata.rb, line 30
def self.stream_name
  "example:command-#{Entity.id}"
end
time() click to toggle source
# File lib/messaging/fixtures/controls/metadata.rb, line 74
def self.time
  ::Time.utc(2000, 1, 1, 0, 0, 0, 11)
end