Использование Spring Cloud Stream с Rabbitmq, с типом обмена "заголовки"

Question

У меня есть проект, настроенный таким образом:

spring:
    cloud:
        stream:
            rabbit:
                bindings:
                    myChannel:
                        consumer:
                            prefetch: 3
                            maxPriority: 10
                            exchangeType: headers
            bindings:
                myChannel:
                    destination: MyChannel
                    group: my-channel-readers
                    consumer:
                        concurrency: 4
                        max-attempts: 3
            binders:
                rabbit:
                    type: rabbit

это действительно создает правильный Exchange (как заголовки) и очередь, но не связывает их.

До того, как я добавилexchangeType: headers создал обмен как topic, а также правильно ограничил очередь.Кроме того, если я переключаю его на exchangeType: topic, он создает привязку правильно.

Я хочу, чтобы это было связано, и отправлял элементы, только если они имеют / не имеют определенный заголовок - как я могу это сделать?

Answer 1

Автоматическое связывание с headers обменом в настоящее время не поддерживается; см. документацию .

exchangeType

Тип обмена: direct, fanout или topic для однораздельных назначений и прямой или раздел для многораздельных назначений.

По умолчанию: тема.

Конечно, вы можете связать его вручную.

Должна быть возможность автоматической привязки к этому типу обмена. Не стесняйтесь, чтобы открыть новый выпуск функции на GitHub .