spring-integration 相关问题

有关Spring Integration项目的问题，请使用此标记。它不适用于将其他Spring项目与其他技术集成的一般问题。

我有一个FtpRemoteFileTemplate： @Autowired 私有 FtpRemoteFileTemplate ftpTemplate；我这样使用它： if (ftpTemplate.exists(fileAbsPath)) { 返回 getRemoteFileAsByteArray(fileAbs...

java spring ftp spring-integration

回答 2 投票 0

如何在从 Sftp.InboundStreamingAdapter 处理文件后删除文件

我目前正在处理来自远程 SFTP 服务器的 .csv 文件，转换它们并将它们放置在 Kafka 主题上。我知道我们可以在使用 Sftp 处理文件后删除文件。

spring-integration spring-dsl

回答 1 投票 0

Spring Integration - 将 json 参数传递给 HttpRequestExecutingMessageHandler

我想使用 SI - HttpRequestExecutingMessageHandler 在 Rest API 的 URL 中传递 json 参数。这是控制器—— @RestController @RequestMapping("/api") 公开课

spring-integration spring-integration-http

回答 0 投票 0

Spring Integration DSL：仅根据消息计数应用聚合器并并行发送到 Http 端点

我对 Spring 注入完全陌生。我正在寻找以下逻辑：消息被发布到队列通道（这可以更改）。我只想做节流使用 Spring Injection 聚合...

java spring-integration spring-integration-dsl

回答 1 投票 0

使用带有文件附件的 gmail 消息的 Spring Integration 流程，例如

Spring Integration 5.x 在这里。我正在尝试编写一个 IntegrationFlow ：从 Gmail 帐户读取电子邮件。如果电子邮件不包含文件附件，它们将被忽略并简单地标记为 &...

gmail spring-integration jakarta-mail

回答 1 投票 0

处理返回 Flux 的 Spring Integration MessageHandler

我的消息处理程序返回一个通量，理想情况下，我希望 spring 集成来处理阻塞/订阅通量，以便我下面的第二个处理程序获得已解析的对象。但是当以下...

spring-boot spring-integration spring-webflux project-reactor spring-integration-dsl

回答 1 投票 0

Spring-Integration DSL transform() 方法使用 bean 的名称作为转换器

创建使用 from() 或 channel() 或 gateway() 的 IntegrationFlow 时，我可以通过简单地提供通道的字符串名称来引用通道。然而，使用

spring spring-integration dsl

回答 0 投票 0

SFTP InboundChannelAdapter 轮询器问题

我的 SFTP 轮询器配置和@InboundChannelAdapter 配置如下我将 ThreadPoolTaskExecutor 配置为队列容量为 5 SftpInboundFileSynchronizingMessageSource 配置为

spring spring-integration spring-integration-sftp

回答 0 投票 0

Spring StreamBridge 在处理流桥上的批量消息时内存不足

我正在使用流桥通过 pubsub 发送消息我有一些 100k 消息需要推送到 pubsub。我正在使用 5 个线程的执行程序池来完成这项工作 private void fetchAndPublish(列表<

spring-integration spring-cloud google-cloud-pubsub spring-cloud-stream spring-gcp

回答 0 投票 0

Spring Integration：通道获取错误的有效载荷

我有这段代码，但它不能正常工作。聚合器获取错误的负载类型 - 实体而不是列表>。谁能解释一下？提前致谢！流水线：...

spring-integration spring-integration-dsl

回答 1 投票 0

带路由的 Spring Integration Java DSL 过滤器

Spring Integration 5.x（Java DSL）。我有兴趣实现一个过滤器作为我的 IntegrationFlow 的一部分，它具有以下逻辑：如果入站消息的标题为“水果”，

java spring-integration

回答 0 投票 0

Spring Integration - split() 和 aggregate() 统计

有没有办法通过启用额外的日志记录级别来了解 split() 和 aggregate() 统计信息？我们有 10k 条消息被拆分并处理了 2 个多小时，任何正在发生的统计数据都会......

spring-integration spring-integration-dsl

回答 0 投票 0

出站网关 HttpRequestExecutingMessageHandler 中的动态参数 uri 更改

我在 for 循环中触发出站网关。迭代在日期范围内，我的目的是用当前迭代中的日期动态更改 uri 的参数。我的迭代...

java spring-boot spring-integration

回答 1 投票 0

启动spring integration channel adapter，等待流程完成

我有一个 spring boot 应用程序，并且有一个要求，我需要轮询数据库以获取某些数据，并在从 db 接收到该数据后，轮询另一个系统以获取更多数据。我用的是弹簧

java spring-boot spring-integration

回答 1 投票 0

如何配置等效于 @Transactional 注释的 TransactionInterceptor 以与 PollerMetadata advice 一起使用

我想配置我的自定义 PollerMetaData bean 以使用 JdbcPollingChannelAdapter 的更新查询启用事务。我正在使用带有 Spring Data JPA 的 Spring boot 和所有自动配置启用...

spring spring-boot transactions spring-integration spring-transactions

回答 0 投票 0

如何使 JdbcPollingChannelAdapter 执行的更新查询具有事务性？

@配置 @EnableIntegration 公共类 IntergrationMain{ @豆公共 MessageChannel aChannel() { 返回新的 DirectChannel(); } @Splitter(inputChannel = "inChannel", outputCh...

spring spring-boot transactions spring-integration spring-transactions

回答 1 投票 0

如何创建 Hazelcast 数据源

大家好，我目前正在尝试将 Hazelcast 用作 Spring Batch 的持久层，为此我需要创建一个由 Hazelcast 支持的数据源。这样项目

java spring spring-integration datasource hazelcast

回答 1 投票 0

在 JSch 中，“无效句柄”是什么意思？

我正在使用 JSch 和 Spring Integration 将文件从我们的 Spring Boot 应用程序存储到 SFTP 服务器。最近，上传开始失败，出现以下错误：原因：org.springframework.mes ...

java spring-boot spring-integration sftp jsch

回答 1 投票 0

收到回复消息但接收线程已经收到回复 - spring 集成错误

这里我有一个 spring 集成流程，当多个并行调用进入这个流程时，我收到错误消息 - 收到回复消息但接收线程已经收到回复：