class Sqreen::Ecosystem::Tracing::Modules::Producer

Public Instance Methods

receive(data) click to toggle source

@param [ModuleApi::Tracing::ProducerData] data

# File lib/sqreen/ecosystem/tracing/modules/producer.rb, line 24
def receive(data)
  signal = Tracing::Signals::TracingProducer.new
  signal.payload = Tracing::Signals::TracingProducer::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