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