问题标签 [spring-integration-amqp]

我们正在使用 ThreadPoolTask​​Executor 来并行化消息处理程序的执行，但我们遇到了并发修改异常。

下面是抛出的异常：

下面是我们的配置：

}

可能是因为 ThreadPoolTask​​Executor 的使用方式或 fileAuditHandler 连接不正确？

RabbitMQ Outbound Gateway 将消息发布到rabbitmq 集群的任何示例参考，我正在寻找带有Spring Boot 的Java 配置

我的 Spring Integration 应用程序使用来自 RabbitMQ 的消息将它们转换为 SOAP 消息并执行 Web 服务请求。

每秒可以从队列中获取许多 (10 – 50) 条消息。或者在应用程序重新启动后，RabbitMQ 队列中可能有数千条消息。

在并行线程中处理多达 10 条消息的最佳可能方案是什么（消息排序很好但不是必需的功能，如果 Web 服务以业务失败回答，那么失败的消息应该重试直到成功）。

Amqp 侦听器不应从队列中消耗更多消息，因为任务执行器中没有可用的繁忙线程。我可以在这样的通道中定义一个 ThreadExecutor：

或者像这样在 AmqpInboundChannelAdapter 中定义一个任务执行器并且不在流定义中定义通道任务执行器就足够了：

或者可能为类似于选项 1 的通道定义任务执行器，但另外在通道适配器上设置 maxConcurrentConsumers，如下所示：

我是 Spring 集成的新手，我想为我的应用程序编写单元测试用例。我正在开发一个应用程序，其中集成接口将由其他系统使用 XML 输入调用，我们使用 XSLT 转换输入 XML，并将调用不同的系统并将响应发送给调用者。

我正在尝试使用 Spring Boot、Spring Batch 和 Spring Integrations 配置 RemoteChunking 任务。

我已经配置了一个activeMQ服务器，并开始按照官方文档https://docs.spring.io/spring-batch/4.0.x/reference/html/spring-batch-integration.html#remote-chunking配置 Spring Batch 。

我的主配置：

我的奴隶配置：

看起来工作正常，但是当从站完成一个块时，它会向完成工作的主站发送响应，并且从站显示“超时错误”：

该代码可在（https://github.com/jamataran/spring-batch-scale）[https://github.com/jamataran/spring-batch-scale]

我正在阅读一条消息，对其进行转换并在 JMS 通道上输出。JMS 通道使用 WorkManager 任务执行器来读取消息并对其进行处理。即使我们将应用服务器中的 WorkManager 配置为有 10 个线程，但只使用了一个线程。

我们是否缺少任何配置，或者是否有其他方法可以读取多个？

为了在 Spring Boot 应用程序中使用 Spring Integration Amqp，我需要包含哪些依赖项？

Spring Boot 版本为 2.0.5。我目前的依赖是spring-boot-starter-integration和spring-integration-amqp

错误消息是类SimpleMessageListenerContainer，AmqpInboundChannelAdapter在类路径中找不到。

更新：我的 build.gradle 条目——

我尝试将 Spring Cloud Contract Verifier Stub Runner 的消息传递模块与 Spring AMQP 集成。我创建SimpleMessageListenerContainer了MessageListener它，它工作正常。但我有另一种方法。我使用 AMQP 支持 Spring Integration with Inbound Channel Adapter 从队列接收消息。是否可以为 AmqpInboundChannelAdapter 使用 Spring Cloud Contract Verifier Stub Runner 的消息传递模块？

合同

应用

测试

例外

如果接收到的消息不是 的有效 JSON UserProfile，则ListenerExecutionFailedException发生并且消息进入 unack 状态。如何将消息发送到死信队列？

和我们这里有类似的情况Spring Cloud Stream 和 RabbitMQ 健康检查

错误信息

环境：

• 爪哇 8
• 圣杯 3.3.8
• spring-rabbit-1.7.9.RELEASE
• spring-boot-actuator-1.5.15.RELEASE
• 密钥斗篷服务器 4.6.0.Final

试图在我的application.yaml文件中禁用 Rabbit 自动配置

spring: autoconfigure: exclude: org.springframework.boot.autoconfigure.amqp.RabbitAutoConfiguration management: context-path: '/manage'

请求： myapp/manage/health

回复 ：

任何想法如何在这里禁用兔子？