Class: Takagi::EventBus::Message

Inherits:
Object
  • Object
show all
Defined in:
lib/takagi/event_bus.rb,
sig/takagi/event_bus.rbs

Overview

Event message wrapper (shareable for Ractor)

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(address, body, headers: {}, reply_address: nil, scope: Scope::DEFAULT, freeze_body: true) ⇒ Message

Returns a new instance of Message.

Parameters:

  • address (Object)
  • body (Object)
  • headers: (::Hash[untyped, untyped]) (defaults to: {})
  • reply_address: (Object, nil) (defaults to: nil) 


36
37
38
39
40
41
42
43
 
# File 'lib/takagi/event_bus.rb', line 36

def initialize(address, body, headers: {}, reply_address: nil, scope: Scope::DEFAULT, freeze_body: true)
  @address = address.freeze
  @body = freeze_body ? deep_freeze(body) : body
  @headers = deep_freeze(headers)
  @reply_address = reply_address&.freeze
  @scope = Scope.normalize(scope)
  @timestamp = Time.now
end

Instance Attribute Details

#address ⇒ Object (readonly)

Returns the value of attribute address.

Returns:

  • (Object) 


34
35
36
 
# File 'lib/takagi/event_bus.rb', line 34

def address
  @address
end

#body ⇒ Object (readonly)

Returns the value of attribute body.

Returns:

  • (Object) 


34
35
36
 
# File 'lib/takagi/event_bus.rb', line 34

def body
  @body
end

#headers ⇒ Object (readonly)

Returns the value of attribute headers.

Returns:

  • (Object) 


34
35
36
 
# File 'lib/takagi/event_bus.rb', line 34

def headers
  @headers
end

#reply_address ⇒ Object (readonly)

Returns the value of attribute reply_address.

Returns:

  • (Object) 


34
35
36
 
# File 'lib/takagi/event_bus.rb', line 34

def reply_address
  @reply_address
end

#scope ⇒ Object (readonly)

Returns the value of attribute scope.



34
35
36
 
# File 'lib/takagi/event_bus.rb', line 34

def scope
  @scope
end

#timestamp ⇒ Object (readonly)

Returns the value of attribute timestamp.

Returns:

  • (Object) 


34
35
36
 
# File 'lib/takagi/event_bus.rb', line 34

def timestamp
  @timestamp
end

Instance Method Details

#deep_freeze(obj) ⇒ Object

Parameters:

  • obj (Object)

Returns:

  • (Object) 


54
55
56
57
58
59
60
61
62
63
64
 
# File 'lib/takagi/event_bus.rb', line 54

def deep_freeze(obj)
  case obj
  when Hash
    obj.transform_keys(&:freeze).transform_values { |v| deep_freeze(v) }.freeze
  when Array
    obj.map { |v| deep_freeze(v) }.freeze
  else
    # String, Symbol, Numeric, TrueClass, FalseClass, NilClass, and others
    obj.freeze
  end
end

#reply(body, headers: {}) ⇒ nil, untyped

Reply to this message (request-reply pattern)

Parameters:

  • body (Object)
  • headers: (::Hash[untyped, untyped]) (defaults to: {})

Returns:

  • (nil, untyped) 


46
47
48
49
50
 
# File 'lib/takagi/event_bus.rb', line 46

def reply(body, headers: {})
  return unless @reply_address

  EventBus.publish(@reply_address, body, headers: headers)
end