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