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