class Sqreen::Ecosystem::Tracing::Modules::Consumer
Public Instance Methods
receive(data)
click to toggle source
@param [ModuleApi::Tracing::ConsumerData] data
# 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