Spring Cloud Stream配置存在问题

Question

我正在尝试升级遗留应用程序的版本。我正在尝试用春云流开发amqp的部分。如果没有交换，我无法在rabbitMQ队列中侦听(我无法更改此方式(如何仅为一个队列实现侦听器？？

这是我的应用程序。yml

cloud:
function:
definition: inputCollector
stream:
default:
contentType: application/json
declareExchange: false
binders:
rabbitmq:
type: rabbit
bindings:
inputCollector-in-0:
queueNameGroupOnly : true
group : collector_result.Collections
binder: rabbitmq

和我的代码

@Configuration
@AllArgsConstructor
public class AnyHandler {
private static final Logger LOG = LoggerFactory.getLogger(InputCollectorHandler.class);
private final CollectorService collectorService;
@Bean
public Consumer<Event> inputCollector() {
return user -> {
LOG.info("event received", user);
try {
anyService.handleCollectorResponse(user);
} catch (Exception e) {
LOG.error("Error processing message: " + user);
}
};
}
}

Answer 1

declareExchange: false必须在...rabbit.defaults...或...rabbit.bindings.....consumer.下

https://docs.spring.io/spring-cloud-stream-binder-rabbit/docs/3.1.1/reference/html/spring-cloud-stream-binder-rabbit.html#_rabbitmq_consumer_properties.