spring-integration 相关问题

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

Spring集成,运动学粘合剂,localstack异常行为

使用测试容器的弹簧集成,运动学结合器和局部堆栈(aws局部环境),我遇到了一个非常奇怪的问题。我有2个频道-A和B。在每个频道上我都有生产者和消费者...

回答 1 投票 0

执行程序通道中的线程安全

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

回答 1 投票 0

使用Spring JdbcMetadataStore(Oracle)时引发DuplicateKeyException

我当前对file:inbound-channel-adapter的配置工作正常。我正在多台服务器上运行该应用程序,实际上只有一台正在处理该文件。数据库表...

回答 1 投票 0

如何使用Spring Integration中的File Watcher仅用于等待,而不用于移动?

我正在Spring Boot应用程序中学习有关Spring Integration的知识,我需要制作一个应用程序以等待文件夹中的.txt文件,然后进行一些处理,然后将生成的.txt文件放入另一个..中。 。

回答 1 投票 1

无法通过SSE向所有连接发送通知

我正在尝试通过服务器发送的事件通知所有用户该事件,但不知道为什么但不起作用。如果我使用队列,但我将配置更改为...

回答 1 投票 0

基于消息的属性值向服务激活器发送消息

我需要根据消息中的属性值将消息发送到特定的服务激活器。因此,当我收到消息时,将执行以下转换返回...

回答 1 投票 0

WildFly 18.x / JBoss EAP 7.x上的Spring Batch分区作业配置

我们正在wildfly集群(版本18)或JBoss EAP 7.x中运行一系列Spring Batch分区作业。我们想在集群周围循环分区。因此出站门方式使用...

回答 1 投票 0

Spring集成多轮询器

我有一个集成,它具有两个不同的集成流程。因此,我将这些流程分为两个不同的类。假设第一个集成流程必须每两个小时工作一次,而另外一个...

回答 1 投票 1


文件夹中的Spring Integration Ftp出站网关特殊字符名称

我正在使用Spring集成的Ftp出站网关从远程ftp服务器获取文件。我正在环境的本地目录中创建文件的副本。我的问题是我无法提取...

回答 1 投票 1

如何使用自定义错误通道来产生自定义错误响应?

我正在尝试使用Spring Integration构建一个简单的API。对于API中引发的任何异常或错误,我想向客户端提供自定义错误响应。我正在尝试使用流结构...

回答 1 投票 0

Spring Mail Integration-如何将org.springframework.messaging.Message转换为javax.mail.internet.MimeMessage

我正在创建一项服务,该服务需要侦听和处理邮件帐户中收到的任何新电子邮件。问题:我无法转换在handleMessageInternal(...)中收到的消息

回答 1 投票 1

带有标头参数的Spring Integration Http OutboundGateway PUT

我正在尝试在远程REST终结点上进行PUT,到目前为止,我需要为其提供凭据作为标头的一部分,但没有成功。方法1:@Bean public IntegrationFlow ...

回答 2 投票 1

无法从设备接收UDP响应

我正在尝试发送UDP请求并接收响应。 Spring Integration具有用于此类任务的适当工具:UnicastSendingMessageHandler和UnicastReceivingChannelAdapter。 ...

回答 1 投票 1

Spring Integration DSL:基于消息有效载荷将消息发送到多个订户(不是所有订户)

我必须创建一个管道来向多个订阅者发送消息,我可以使用publishSubscribeChannel实现这一点。但是对于我来说,当我收到消息时-我有一个eventSubType,例如

回答 1 投票 0

ClassNotFoundException:尝试升级Spring Boot版本时,org.springframework.kafka.listener.config.ContainerProperties

我正在开发一个示例Spring集成项目,该项目具有使用spring集成的kafka监听器。这在较低版本的boot(boot-1.5.9,kafka-client 1.0.0,spring -...]下工作正常

回答 1 投票 0

Spring集成:无法在超时内将消息发送到通道'executionFilterChannel':-1

[当我尝试使用通道消息存储时出现以下错误:-org.springframework.messaging.MessageDeliveryException:无法将消息发送到...内的通道'executionFilterChannel'

回答 1 投票 0

spring-cloud-stream应用程序正在寻找不存在的org.springframework.integration.endpoint.Pausable

我基于一个官方示例尝试的一个简单的spring-boot应用程序由于一个奇怪的错误而失败了。 spring-cloud-stream中的某个类正在寻找org.springframework ....

回答 1 投票 0

@ Poller-s在Spring Integration中如何工作?

我正在构建具有两个PollableChannels的Sprint集成的实现:常规通道错误通道从常规通道中轮询消息并进行处理。如果在...期间出现错误,则]

回答 1 投票 0

Spring Azure qPID JMS代码中的跟踪内存泄漏

我试图在我们非常小的和简单的Spring Boot应用程序中跟踪和识别导致内存泄漏的根本原因。它使用以下命令:-Spring Boot 2.2.4-azure-servicebus-jms-spring-boot-starter 2.2 ....

回答 1 投票 1

© www.soinside.com 2019 - 2024. All rights reserved.