Трассировка в Spring Integration (Spring boot 3.0.9)

Я пытаюсь использовать интеграцию Spring: получаю сообщение через JMS и отправляю его в Кафку:

    @Override
    protected IntegrationFlowDefinition<?> buildFlow() {
        return from(Jms.messageDrivenChannelAdapter(connectionFactory).destination(mqInQueue))
                .log(LoggingHandler.Level.DEBUG, message -> "Received JMS message: " + message.getPayload())
                .channel(channels -> MessageChannelFactory.create(channels, "request-channel-1"))
                .handle(Kafka.outboundChannelAdapter(kafkaTemplate).topic(kafkaOutTopic));
    }

Для проверок я отправляю сообщения в MQ, используя запрос POST + JmsTemplate:

    @PostMapping("/mq")
    public String sentToMq(@RequestBody final String body) {
        jmsTemplate.convertAndSend(mqRequestQueue, body, m -> {
            final var span = tracer.startScopedSpan("jms-send");
            try {
                final var context = span.context();
                m.setStringProperty("b3", "%s-%s-%s".formatted(context.traceId(), context.spanId(), Boolean.TRUE.equals(context.sampled()) ? "1" : "0"));
            } finally {
                span.end();
            }

            return m;
        });
        return "done";
    }

Все работает нормально, кроме трассировки. Я устанавливаю заголовок b3 вручную перед отправкой, но после получения Spring Integration отменяет его. Что мне следует сделать, чтобы сохранить входящий идентификатор трассировки?

Также у меня есть следующая конфигурация:

• @EnableIntegrationManagement(observationPatterns = "*")

•   @Bean
    @GlobalChannelInterceptor(order = Ordered.HIGHEST_PRECEDENCE)
    public ChannelInterceptor observationPropagationChannelInterceptor(final ObservationRegistry observationRegistry) {
        return new ObservationPropagationChannelInterceptor(observationRegistry);
    }