Class: Messaging::Message::Metadata

Inherits:
Object
  • Object
show all
Includes:
Schema::DataStructure
Defined in:
lib/messaging/message/metadata.rb

Defined Under Namespace

Classes: Error

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.transient_attributes ⇒ Object 



88
89
90
91
92
93
94
95
 
# File 'lib/messaging/message/metadata.rb', line 88

def self.transient_attributes
  [
    :stream_name,
    :position,
    :global_position,
    :time
  ]
end

Instance Method Details

#causation_message_identifier ⇒ Object Also known as: causation_identifier 



42
43
44
45
 
# File 'lib/messaging/message/metadata.rb', line 42

def causation_message_identifier
  return nil if causation_message_stream_name.nil? || causation_message_position.nil?
  "#{causation_message_stream_name}/#{causation_message_position}"
end

#clear_reply_stream_name ⇒ Object 



65
66
67
 
# File 'lib/messaging/message/metadata.rb', line 65

def clear_reply_stream_name
  self.reply_stream_name = nil
end

#correlated?(stream_name) ⇒ Boolean Also known as: correlates?

Returns:

  • (Boolean) 


73
74
75
76
77
78
79
80
81
82
83
84
85
 
# File 'lib/messaging/message/metadata.rb', line 73

def correlated?(stream_name)
  correlation_stream_name = self.correlation_stream_name

  return false if correlation_stream_name.nil?

  stream_name = Category.normalize(stream_name)

  if MessageStore::StreamName.category?(stream_name)
    correlation_stream_name = MessageStore::StreamName.get_category(correlation_stream_name)
  end

  correlation_stream_name == stream_name
end

#follow(preceding_metadata) ⇒ Object 



48
49
50
51
52
53
54
55
56
 
# File 'lib/messaging/message/metadata.rb', line 48

def follow(preceding_metadata)
  self.causation_message_stream_name = preceding_metadata.stream_name
  self.causation_message_position = preceding_metadata.position
  self.causation_message_global_position = preceding_metadata.global_position

  self.correlation_stream_name = preceding_metadata.correlation_stream_name

  self.reply_stream_name = preceding_metadata.reply_stream_name
end

#follows?(metadata) ⇒ Boolean

Returns:

  • (Boolean) 


58
59
60
61
62
63
 
# File 'lib/messaging/message/metadata.rb', line 58

def follows?(metadata)
  causation_message_stream_name == metadata.stream_name &&
    causation_message_position == metadata.position &&
    causation_message_global_position == metadata.global_position &&
    reply_stream_name == metadata.reply_stream_name
end

#identifier ⇒ Object Also known as: source_message_identifier 



36
37
38
39
 
# File 'lib/messaging/message/metadata.rb', line 36

def identifier
  return nil if stream_name.nil? || position.nil?
  "#{stream_name}/#{position}"
end

#reply? ⇒ Boolean

Returns:

  • (Boolean) 


69
70
71
 
# File 'lib/messaging/message/metadata.rb', line 69

def reply?
  !reply_stream_name.nil?
end