class Trace::SqsClient
Public Instance Methods
perform(sqs_options, queue_name, spans)
click to toggle source
# File lib/zipkin-tracer/zipkin_sqs_sender.rb, line 11 def perform(sqs_options, queue_name, spans) spans_with_ips = ::ZipkinTracer::HostnameResolver.new.spans_with_ips(spans, ZipkinSqsSender::IP_FORMAT).map(&:to_h) sqs = Aws::SQS::Client.new(**sqs_options) queue_url = sqs.get_queue_url(queue_name: queue_name).queue_url body = JSON.generate(spans_with_ips) sqs.send_message(queue_url: queue_url, message_body: body) rescue Aws::SQS::Errors::NonExistentQueue error_message = "The queue '#{queue_name}' does not exist." SuckerPunch.logger.error(error_message) rescue => e SuckerPunch.logger.error(e) end