有关Spring Integration项目的问题,请使用此标记。它不适用于将其他Spring项目与其他技术集成的一般问题。
Spring 集成流程:寻找避免由于递归流程而导致 java.lang.StackOverflowError 的策略
使用 Spring-Integration 版本 5.5.18,我有一个流程,该流程适用于小型输入集,但由于通过 c... 递归调用,因此对于较大的输入集会遇到 java.lang.StackOverflowError 。
执行器通道和直接通道之间的差异 - 直接通道在失败时将消息加倍,但执行器通道在相同情况下不会加倍
我正在尝试使用 Spring Integration 框架查找 java 应用程序中 Executor Channel 和 Direct Channel 之间行为不同的原因。 我想检查故障转移流程并确保消息...
TcpNioConnection 关闭抛出异常(java.nio.channels.ClosedChannelException)
场景是我们需要配置 maxClient,如果达到它,我们必须关闭连接(如果它大于 maxClient)。为此,我们在列表中添加connectionId,如果列表更大
迁移到 Spring Boot 3 - 如何处理来自服务器的“[email protected]”请求?
我们的团队有一个应用程序,每天使用 Spring Integration SFTP 从远程服务器获取和处理一次文件。现在,我正在从 Spring Boot 2.7 迁移到 Spring Boot 3。 之后
我有以下配置,并且我在Spring集成Java DSL服务执行器(.handle)中使用了以下样式,应该使用bean @豆 公共 IntegrationFlow 流程(PollerMetada
我在 Spring Integration - MessagingGateway 方面遇到问题。我创建了网关接口,并将两个 ServiceActivator 附加到它的 requestChannel 上。 一切正常,但我想监控...
使用 Spring Integration 将对象转换为 JSON 到 MQTT 负载
我正在尝试使用 Spring Integration 通过 MQTT 消息发送 JSON 作为有效负载。这是我的出站处理程序: @豆 @ServiceActivator(inputChannel = MQTT_OUTBOUND_CHANNEL) 公开
使用Spring Integration Sftp上传文件时写入文件失败
我尝试使用 emberstack/sftp 或 atmoz/sftp 在 Docker 容器中托管 sftp 服务器以进行测试。 sftp: 图片:emberstack/sftp 卷: - ./data/sftp.json:/app/config...
如何重启SimpleMessageListenerContainer
我尝试使用 Spring Boot 连接到 RabbitMQ。连接应始终重新启动/重试连接。我在发生致命异常后重新连接时遇到问题。应用程序永远不会丢失
在 JUnit 集成测试中启动 Spring Integration 轮询器的简洁方法
我有一个 Spring Integration 流程,它利用 MessageSource 定期填充来自数据库查询的消息(不,我不打算使用 Spring Integration JPA/JDBC) @豆 公开
Spring集成升级问题。无法注册 MBean [bean 'org.springframework.integration.config.RouterFactoryBean#0'
我已将spring(无启动)应用程序升级到java 17和spring 6.1.3,spring集成的版本也从4.1.2.RELEASE升级到6.2.1。我已经成功构建了 jar,但是当我...
我有简单的 Outlook 邮件接收器,带有轮询器和任务执行器。 每 25 秒轮询一次固定延迟 每次轮询的最大消息数 2 最大获取大小 1 邮箱有8封邮件 第一次民意调查需要 2 条消息和 fetc...
我有一个简单的案例,我需要使用 Spring Cloud Stream 3.2.4 版本来实现。 我有一个预定的消息生产者: 公共类 MySourceOfMessagesImpl { 私人随机随机...
当未提供“通道”引用时,需要通道适配器的“id”属性,因为“id”将用于创建的通道
我正在使用 spring-integration-kafka 1.1.2 版本并面临此错误,我无法定义 id,因为它不允许我这样做,请帮忙。 已添加此代码与 Spring 集成侦听器自定义
我通过 Josh Long YouTube 视频了解了 Spring Integration,我认为它非常适合我们的一个业务案例。 我们想做的事情在纸面上很简单:数据复制。 W...
如何使用 transactionSynchronizationFactory 将文件从入站远程目录移动到另一个远程目录
我的要求是从 FTP 远程目录读取文件,将有效负载值插入数据库,然后将文件从远程目录 /in 移动到同一 FTP 服务器的远程目录 /archive。 我是
如何删除Spring集成的ftp inbound-channel-adapter中的本地文件
我有一个集成案例,从 FTP 获取 xml 有效负载,然后使用 http 出站通道将有效负载发送到 Web 服务,ftp 入站通道适配器有一个名为 local-directory 的强制属性,
Spring Integration:使用 Spring Integration 进行多应用程序集成
我对 Spring Integration 有一些疑问: 我们可以使用 Spring Integration 框架集成两个以上的应用程序吗? 是点对点集成还是面向中间件的集成...
IntegrationFlow 可分割集合并为每个消息创建一个事务
我之前创建了一个集成流程,该流程使用带有 updateExpression 的 MongoDb inboundChannelAdapter 并将其设置为事务性: 集成流程 .来自(MongoDb.
Mqttv5PahoMessageDrivenChannelAdapter 正在创建带有客户端 ID 前缀的主题
我正在 Spring Boot 应用程序中嵌入 ActiveMQ Artemis,并尝试使用 Spring Integration 中的 Mqttv5PahoMessageDrivenChannelAdapter 连接到 MQTT 端口: @豆 公共客户经理...