spring-integration-dsl 相关问题

Spring Integration在下一个之前完成异步转换

我有一个集成流，该流会定期轮询数据库以检索尚未处理的任何MachineLine实体并对其进行处理。该流程检索MachineLine的集合...

Spring Integration Mail：在所有数据库插入后发送电子邮件

您好，我有一个集成流程，该流程将文件逐行拆分，将每一行转换为一个POJO，然后通过JDBC出站网关将该POJO插入db。我希望能够发送一个...

Spring集成-消息偶尔不会得到处理，将进入空通道

我正在使用SI的聚合器，并使用自定义聚合器和发布策略。 PFB代码段返回IntegrationFlows.from（“ uaDefaultChannel”）。wireTap（UA_WIRE_TAP_CHNL）.transform（eventHandler，...

多线程执行器通道可加速使用者进程

我有一个消息生成器，它每秒产生约15条消息。消费者是一个Spring集成项目，它从Message Queue中进行消耗并进行大量处理。当前是...

如果成功传递到队列，Spring Integration DSL答复成功

我正在尝试公开HTTP端点，如果传递成功，则该HTTP端点会将消息丢弃到JMS队列中。如果传递成功，消息将通过“成功”回复；如果传递失败，则失败。 @Bean public ...

Spring IntegrationFlow正则表达式过滤器不起作用

我有两个过滤器regexFilter和lastModified。返回IntegrationFlows.from（Sftp.inboundAdapter（inboundSftp）.localDirectory（this.getlocalDirectory（config.getId（）））....

Spring文件集成Java配置

我想使用Spring集成来开发应用程序，以便在可用时轮询目录中的文件。将文件复制到存档目录，处理文件，然后将路径添加到...

执行程序的Spring Integration DSL自定义错误通道问题

[嗨，我有一个文件侦听器，它正在并行读取文件，一次读取多个文件，包com.example.demo.flow;导入lombok.extern.slf4j.Slf4j;导入org.springframework.context.annotation.Bean; ...

Docker容器中的Spring Integration FTP：未触发流程

我花了很多时间弄清楚我的问题的根源。我可以在本地运行，也可以构建.jar并在本地运行。我的集成流程如下所示：@Bean ...

IntegrationMBeanExporter.stopActiveComponents（）与gcp发布/订阅生产者一起抛出了InterruptedExceptions负载

我们有以下（简化的）流程：->入站FILE API从具有固定轮询器的远程服务器读取文件->分离器，通过直接通道连接-> GCP发布/订阅生产者，读取消息...]]

Spring Integration 5.2.2.RELEASE-使用@IntegrationConverter进行集成流转换不适用于杰克逊数据绑定

我将Spring Boot版本从2.1.8.RELEASE升级到2.2.2.RELEASE（因此Spring Integration从5.1升级到5.2.2.RELEASE），并且如果..，使用@IntegrationConverter的自动投射似乎不再起作用。 。

Spring Integration DSL FTP

我有用于FTP的Spring入站，我正在查看文档https://docs.spring.io/spring-integration/reference/html/ftp.html。如果您碰巧在本地本地存储了一个或多个文件， ...

如何定制弹簧集成流程

[我有一个类似FTP的文件的要求，将文件复制到本地目录，将文件拾取到服务器1进行解析和读取服务2，以丰富XYZ服务3，以丰富CDY服务4，以持久保存...]]

如何要求Spring为JdbcMetadataStore创建相应的架构？

我想使用在此描述的jdbc元数据存储：https://docs.spring.io/spring-integration/docs/5.2.0.BUILD-SNAPSHOT/reference/html/jdbc.html#jdbc-metadata-store quote：组织。...

如何在Spring Integration中在运行时解决jms出站目标队列，

因此，目标队列由MSG_TYPE从源目录中的.txt文件确定，该目录是集成流程的源。如果MSG_TYPE以“ ORU”开头，则发送到队列“ jms / dataqueue”，如果...

我们可以使用Couchbase作为Spring Integration的消息存储库吗

我们正在实现Spring Integration聚合器，并使用JDBC消息数据存储。在我们的环境中，我们拥有Couchbase和Oracle DB。我不想使用Oracle DB，我们可以使用Couchbase作为...

一种连接中的多种协议

我有一个非常奇怪的情况，TCP服务器基本上维护两个协议。第一个消息对发送STX | PAYLOAD | ETX消息，并返回相同的STX | PAYLOAD | ETX消息类型。 ...

延迟的入站适配器和控制总线

我的集成流代码是：@Bean public IntegrationFlow messageFlow（）{return IntegrationFlows.from（stompInboundChannelAdapter（））.transform（inBoundStompMsgTransformer :: ...

Spring入站通道适配器与应用程序事件列表消息生成器之间的区别

我正在使用Spring Integration和STOMP进行POC。初始POC成功。我遵循了https：//docs.spring.io/spring-integration/reference/html / ...

是否可以使用java注释在spring-integration中编写过滤器？

我正在尝试在spring-integration中转换xml配置，并且遇到了类似这样的过滤器： ] >> < [ 我不确定我是否完全理解你的问题。如果您使用注释，则其全部原因是因为您具有在SpEL中表达 cannot 或should not的一些复杂逻辑，因此它使您有机会编写一些Java代码并让框架知道这是一个过滤器。也有DSL，我认为这篇文章涵盖得很好-spring integration dsl filter instead filter method annotation