Module: Messaging::Controls::Metadata
- Defined in:
- lib/messaging/controls/metadata.rb
Defined Under Namespace
Modules: New, Random, Written
Constant Summary
collapse
- Empty =
New
Class Method Summary
collapse
Class Method Details
.causation_message_global_position ⇒ Object
24
25
26
|
# File 'lib/messaging/controls/metadata.rb', line 24
def self.causation_message_global_position
222
end
|
.causation_message_identifier ⇒ Object
44
45
46
|
# File 'lib/messaging/controls/metadata.rb', line 44
def self.causation_message_identifier
"#{causation_message_stream_name}/#{causation_message_position}"
end
|
.causation_message_position ⇒ Object
20
21
22
|
# File 'lib/messaging/controls/metadata.rb', line 20
def self.causation_message_position
11
end
|
.causation_message_stream_name ⇒ Object
16
17
18
|
# File 'lib/messaging/controls/metadata.rb', line 16
def self.causation_message_stream_name
"someCausation"
end
|
.correlation_stream_name ⇒ Object
28
29
30
|
# File 'lib/messaging/controls/metadata.rb', line 28
def self.correlation_stream_name
"someCorrelation"
end
|
.data ⇒ Object
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
|
# File 'lib/messaging/controls/metadata.rb', line 56
def self.data
{
stream_name: stream_name,
position: 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,
global_position: global_position,
time: time,
schema_version: schema_version
}
end
|
.global_position ⇒ Object
48
49
50
|
# File 'lib/messaging/controls/metadata.rb', line 48
def self.global_position
111
end
|
.identifier ⇒ Object
40
41
42
|
# File 'lib/messaging/controls/metadata.rb', line 40
def self.identifier
"#{stream_name}/#{position}"
end
|
.position ⇒ Object
12
13
14
|
# File 'lib/messaging/controls/metadata.rb', line 12
def self.position
1
end
|
.reply_stream_name ⇒ Object
32
33
34
|
# File 'lib/messaging/controls/metadata.rb', line 32
def self.reply_stream_name
"someReply"
end
|
.schema_version ⇒ Object
36
37
38
|
# File 'lib/messaging/controls/metadata.rb', line 36
def self.schema_version
'1.1'
end
|
.stream_name ⇒ Object
8
9
10
|
# File 'lib/messaging/controls/metadata.rb', line 8
def self.stream_name
'someSource'
end
|
.time ⇒ Object
52
53
54
|
# File 'lib/messaging/controls/metadata.rb', line 52
def self.time
Time::Raw.example
end
|