Выражение функциональной маршрутизации Spring Cloud RabbitMQ не работает ⇐ JAVA

[Anonymous]

Я переношу старое приложение Spring Boot 2.3.3 на Spring Boot 3.3

Приложение использует Spring Cloud и RabbitMQ.

Старое приложение: Spring Boot 2.3. 3 с Spring Cloud Hoxton.SR8

Новинка: Spring Boot 3.3.1 с Spring Cloud 2023.0.2
Я изменил конфигурацию и код Spring для использования новая модель функционального программирования Spring Cloud для Rabbit Queues.

https://docs.spring.io/spring-cloud-fun ... model.html
Я уже выполнял эту миграцию в другом приложении, но на этот раз я столкнулся с проблемой маршрутизации, которую не могу найти, как ее решить.
У меня есть две входящие очереди с одинаковым именем назначения, но с заголовком ключа маршрутизации, позволяющим определить, в какую функцию направить сообщение.

Однако я не могу заставить эту маршрутизацию работать после миграции. Модульные тесты, которые до миграции работали нормально, теперь терпят неудачу.

Это связано с тем, что одно сообщение DeliveryMessage или CargoMessage направляется в обе функции (processDelivery;processCargo).
Возможно, у двух очередей должны были быть разные имена назначения, но я ничего не могу с этим поделать, так как не могу изменить приложение (службу хранения), отправляющее эти сообщения. .
cloud:
function:
definition: processBaseDelivery;processDelivery;processCargo
#routing-expression: "headers.amqp_receivedRoutingKey.toString().contains('delivery') ? 'processDelivery' : 'processCargo'"
routing-expression: "headers['amqp_receivedRoutingKey'] == 'delivery.INSERT' ? 'processDelivery' : 'processCargo'"
stream:
bindings:
processBaseDelivery-in-0:
destination: transport.baseDeliveryResponse
group: delivery-service
processDelivery-in-0:
destination: storage
group: delivery-service.delivery
processCargo-in-0:
destination: storage
group: delivery-service.cargo
rabbit:
bindings:
processBaseDelivery-in-0:
consumer:
transacted: true
requeue-rejected: true
bindingRoutingKey: delivery.response
processDelivery-in-0:
consumer:
max-concurrency: 1
autoBindDlq: true
transacted: true
requeue-rejected: false
bindingRoutingKey: delivery.*
processCargo-in-0:
consumer:
max-concurrency: 1
autoBindDlq: true
transacted: true
requeue-rejected: false
bindingRoutingKey: cargo.*

Мой модульный тест для процесса доставки с доставкой. ВСТАВЬТЕ в качестве ключа маршрутизации.
@SpringBootTest
@ExtendWith(MockitoExtension.class)
@ActiveProfiles("it")
@Import(TestChannelBinderConfiguration.class)
public class MessageProcessorServiceTest {

@MockBean
private CargoService cargoService;

@MockBean
private DeliveryService deliveryService;

@Autowired
private InputDestination inputDestination;

@Test
public void processDelivery_delete() {
final DeliveryMessage deliveryMessage = new DeliveryMessage();
deliveryMessage.setId(1L);
deliveryMessage.setOperation(Operation.DELETE);

inputDestination.send(
MessageBuilder.withPayload(deliveryMessage)
.setHeader(AmqpHeaders.RECEIVED_ROUTING_KEY, "delivery.INSERT")
.build(), "lagerlegging");

Mockito.verify(deliveryService, new Times(1))
.deleteDelivery(eq(1L));
Mockito.verifyNoInteractions(cargoService);
}

}

Я пробовал использовать Consumer с Message и без него для обеих функций:
public Consumer processDelivery()
public Consumer processDelivery()


Подробнее здесь: https://stackoverflow.com/questions/788 ... ot-working