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