有关Spring Integration项目的问题,请使用此标记。它不适用于将其他Spring项目与其他技术集成的一般问题。
Spring Integration SFTP每天获取但立即处理
我想每天过滤和提取文件,然后立即处理所有过滤的文件。这是我的配置; @Bean public SftpInboundFileSynchronizer sftpInboundFileSynchronizer(){...
您能提供有关Spring集成配置的帮助吗?收到消息后,我得到:org.springframework.messaging.MessageDeliveryException:调度程序没有频道'myapp-1 .....
根据文档,JDBCMetadataStore需要一个DataSourceTransactionManager实例,这很有意义。如果我在应用程序中使用JPA作为主要事务管理器怎么办?我该如何...
我有以下Spring Integration JAva DSL代码:返回流-> flow.channel(INPUT_CHANNEL).transform(customMapper,“ mapFrom”).enrichHeaders(...
Spring Integration返回500错误而不是400错误
我确实需要您提供有关在Spring Integration中将其DefaultResponseErrorHandler类用于出站网关的错误处理的建议。目前,对于xml-config ...
我正在编写一个集成测试,其中我使用堆栈来旋转模拟AWS服务的localstack docker容器。此代码将启动Docker容器@RunWith(LocalstackTestRunner.class)@ ...
Spring集成测试-不带RunWith注释的自动装配类(AWS localstack)
我正在尝试编写集成测试。我想使用本地堆栈启动模拟AWS服务的docker容器。此代码将启动docker容器,但不会自动装配...
是否有任何已实现的SubscribableChannel / EventDrivenConsumer可以在Spring Integration Kafka使用者中使用?
到目前为止,我发现的都是PollableChannel / PollableConsumer实现,例如:https://github.com/spring-projects/spring-integration-samples/blob/master/basic/kafka我仍然需要保持...
Spring集成,运动学粘合剂,localstack异常行为
使用测试容器的弹簧集成,运动学结合器和局部堆栈(aws局部环境),我遇到了一个非常奇怪的问题。我有2个频道-A和B。在每个频道上我都有生产者和消费者...
我有一个消息生成器,它每秒产生约15条消息。消费者是一个Spring集成项目,它从Message Queue中进行消耗并进行大量处理。我用过...
使用Spring JdbcMetadataStore(Oracle)时引发DuplicateKeyException
我当前对file:inbound-channel-adapter的配置工作正常。我正在多台服务器上运行该应用程序,实际上只有一台正在处理该文件。数据库表...
如何使用Spring Integration中的File Watcher仅用于等待,而不用于移动?
我正在Spring Boot应用程序中学习有关Spring Integration的知识,我需要制作一个应用程序以等待文件夹中的.txt文件,然后进行一些处理,然后将生成的.txt文件放入另一个..中。 。
我正在尝试通过服务器发送的事件通知所有用户该事件,但不知道为什么但不起作用。如果我使用队列,但我将配置更改为...
我需要根据消息中的属性值将消息发送到特定的服务激活器。因此,当我收到消息时,将执行以下转换返回...
WildFly 18.x / JBoss EAP 7.x上的Spring Batch分区作业配置
我们正在wildfly集群(版本18)或JBoss EAP 7.x中运行一系列Spring Batch分区作业。我们想在集群周围循环分区。因此出站门方式使用...
我有一个集成,它具有两个不同的集成流程。因此,我将这些流程分为两个不同的类。假设第一个集成流程必须每两个小时工作一次,而另外一个...
具有void方法的Spring Integration Gateway返回类型:为什么它不自动设置NullChannel replyChannel?
我使用Spring Integration 4.3.x具有这样的集成流程: => => => => ...
文件夹中的Spring Integration Ftp出站网关特殊字符名称
我正在使用Spring集成的Ftp出站网关从远程ftp服务器获取文件。我正在环境的本地目录中创建文件的副本。我的问题是我无法提取...
我正在尝试使用Spring Integration构建一个简单的API。对于API中引发的任何异常或错误,我想向客户端提供自定义错误响应。我正在尝试使用流结构...
Spring Mail Integration-如何将org.springframework.messaging.Message转换为javax.mail.internet.MimeMessage
我正在创建一项服务,该服务需要侦听和处理邮件帐户中收到的任何新电子邮件。问题:我无法转换在handleMessageInternal(...)中收到的消息