有关Spring Integration项目的问题,请使用此标记。它不适用于将其他Spring项目与其他技术集成的一般问题。
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(...)中收到的消息
带有标头参数的Spring Integration Http OutboundGateway PUT
我正在尝试在远程REST终结点上进行PUT,到目前为止,我需要为其提供凭据作为标头的一部分,但没有成功。方法1:@Bean public IntegrationFlow ...
我正在尝试发送UDP请求并接收响应。 Spring Integration具有用于此类任务的适当工具:UnicastSendingMessageHandler和UnicastReceivingChannelAdapter。 ...
Spring Integration DSL:基于消息有效载荷将消息发送到多个订户(不是所有订户)
我必须创建一个管道来向多个订阅者发送消息,我可以使用publishSubscribeChannel实现这一点。但是对于我来说,当我收到消息时-我有一个eventSubType,例如
我正在开发一个示例Spring集成项目,该项目具有使用spring集成的kafka监听器。这在较低版本的boot(boot-1.5.9,kafka-client 1.0.0,spring -...]下工作正常
Spring集成:无法在超时内将消息发送到通道'executionFilterChannel':-1
[当我尝试使用通道消息存储时出现以下错误:-org.springframework.messaging.MessageDeliveryException:无法将消息发送到...内的通道'executionFilterChannel'
spring-cloud-stream应用程序正在寻找不存在的org.springframework.integration.endpoint.Pausable
我基于一个官方示例尝试的一个简单的spring-boot应用程序由于一个奇怪的错误而失败了。 spring-cloud-stream中的某个类正在寻找org.springframework ....
@ Poller-s在Spring Integration中如何工作?
我正在构建具有两个PollableChannels的Sprint集成的实现:常规通道错误通道从常规通道中轮询消息并进行处理。如果在...期间出现错误,则]
Spring Azure qPID JMS代码中的跟踪内存泄漏
我试图在我们非常小的和简单的Spring Boot应用程序中跟踪和识别导致内存泄漏的根本原因。它使用以下命令:-Spring Boot 2.2.4-azure-servicebus-jms-spring-boot-starter 2.2 ....