Adds tracing headers to messages sent via Spring Cloud AWS's SqsTemplate

TracingSqsTemplateConfig.java

@Bean
SqsTemplate sqsTemplate(SqsAsyncClient sqsAsyncClient, ObjectMapper objectMapper, Tracing tracing) {
    var injector = tracing.propagation().injector(
            (Propagation.Setter<Map<String, Object>, String>) (headersMap, key, value) -> {
                // only propagate the traceparent attr, no additional baggage, since SQS only supports a max of 10 attrs
                if (key.startsWith("trace")) headersMap.put(key, value);
            });
    var converter = new SqsMessagingMessageConverter() {
        @Override
        public Message fromMessagingMessage(org.springframework.messaging.Message<?> message, MessageConversionContext context) {
            Span span = tracing.tracer().nextSpan()
                    .kind(Span.Kind.PRODUCER)
                    .name("send")
                    .remoteServiceName("sqs")
                    .start();
            Map<String, Object> newHeaders = new HashMap<>();
            injector.inject(span.context(), newHeaders);
            span.finish();
            return super.fromMessagingMessage(MessageHeaderUtils.addHeadersIfAbsent(message, newHeaders), context);
        }
    };
    converter.setObjectMapper(objectMapper);

    return SqsTemplate.builder()
            .sqsAsyncClient(sqsAsyncClient)
            .messageConverter(converter)
            .build();
}