Class: Sqreen::Ecosystem::Tracing::Modules::Consumer

Inherits:
Object
  • Object
show all
Includes:
Loggable, ModuleApi::Tracing, ModuleApi::TracingIdGeneration
Defined in:
lib/sqreen/ecosystem/tracing/modules/consumer.rb

Instance Attribute Summary

Attributes included from ModuleApi::TracingIdGeneration

#tracing_id_producer

Attributes included from ModuleApi::SignalProducer

#tracing_id_producer

Instance Method Summary collapse

Methods included from ModuleApi::Tracing

#consumed_type, included, #scope

Instance Method Details

#receive(data) ⇒ Object

Parameters:



24
25
26
27
28
29
30
31
32
33
34
35
 
# File 'lib/sqreen/ecosystem/tracing/modules/consumer.rb', line 24

def receive(data)
  signal = Tracing::Signals::TracingConsumer.new
  signal.payload = Tracing::Signals::TracingConsumer::Payload.new(
    message_type: data.message_type,
    host: data.host || '',
    ip: data.ip,
    topic: data.topic,
    tracing_identifier: data.tracing_identifier || create_tracing_id
  )

  submit_signal signal
end