我正在嘗試將使用 Spring Integration 4.3 和 Spring Boot 1.6 的項(xiàng)目升級(jí)到 Spring Integration 5.1 和 Spring Boot 2.1。以前我有以下配置：IntegrationFlows.from(Amqp.inboundAdapter(connectionFactory, "queueName") .id("myId") .autoStartup(autoStartup) .prefetchCount(10) .concurrentConsumers(2) .maxConcurrentConsumers(3) .messageConverter(messageConverter())) .aggregate(a -> a.correlationExpression("payload.entityId") .releaseExpression("size() eq iterator().next().payload.batchSize") .sendPartialResultOnExpiry(true) .groupTimeout(2000) .expireGroupsUponCompletion(true) .outputProcessor(myMessageGroupProcessor)) .handle(serviceActivatorBean, "myMethod", e -> e.advice(requestHandlerRetryAdviceForIntegrationFlow())) .get();在升級(jí)過程中，我嘗試按照此處的文檔進(jìn)行操作，因此將配置更改為：@Configuration@EnableAutoConfiguration@EnableIntegrationpublic class SpringConfig { @Bean(name = "myFlowId") public IntegrationFlow myFlow(ConnectionFactory connectionFactory, ServiceActivatorBean serviceActivatorBean, @Value("${spring.integration.flow.auto-startup:true}") boolean autoStartup, MyMessageGroupProcessor myMessageGroupProcessor) { }}但是，當(dāng)我發(fā)布消息時(shí)，集成流似乎沒有接收/處理它們。我沒有收到任何錯(cuò)誤日志（或者即使我啟用了調(diào)試日志記錄也沒有任何日志），而且我不太確定從哪里開始調(diào)試。我很肯定消息實(shí)際上已發(fā)布到 RabbitMQ，所以這不是問題。我會(huì)錯(cuò)過什么？
1 回答
撒科打諢
TA貢獻(xiàn)1934條經(jīng)驗(yàn) 獲得超2個(gè)贊
我的問題實(shí)際上不是由于 Spring Integration，而是與 Spring AMQP 的變化有關(guān)。以前的“可聲明”可以這樣創(chuàng)建：
@Bean
List<Binding> myBinding() {
return List.of(<binding1>, <binding2>, ..)
}
但在 Spring AMQP 2.1 中，這應(yīng)該更改為：
@Bean
Declarables myBinding() {
return new Declarables(List.of(<binding1>, <binding2>, ..))
}
請(qǐng)參閱此處的文檔。
順便說一句，我releaseExpression的也錯(cuò)了，應(yīng)該是size() eq one.payload.batchSize。
添加回答
舉報(bào)
0/150
提交
取消