spring-integration 相关问题

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

Spring-Integration 应用程序在迁移到 Azure Spring Apps 服务后缺少一些集成指标

我们有 Spring-Integration 微服务，它使用 JMS 来处理 MQ 消息。消息管理器应用程序（另一个应用程序）对这个应用程序进行其余调用以获取有关成功和失败混乱的统计信息...

spring-boot azure spring-integration metrics jmx-exporter

回答 1 投票 0

Spring 集成 Java DSL TCP 出站和入站连接处理程序

我需要创建一个动态 TCP 出站适配器，充当客户端、连接到服务器并处理服务器的响应。虽然请求已正确发送到服务器，但我无法

java spring-boot tcp spring-integration spring-integration-dsl

回答 1 投票 0

Spring 集成 TCP 服务器到客户端请求响应

我有一个用例，我需要使用 TCP 套接字向外部系统发出请求并等待响应。我知道如果我作为客户端连接，则可以使用 Spring Integration Outbound Gateway....

spring spring-boot spring-integration tcpsocket

回答 1 投票 0

FTP 入站适配器在 SQS 消息发送后将文件发送到远程

我正在实现一个 @InboundChannelAdapter 场景，其中我需要在将消息发送到 AWS SQS 队列后将文件移动到远程存档目录。我已经成功实现了类似的场景

java spring-boot spring-integration spring-integration-aws spring-integration-ftp

回答 1 投票 0

使用 serviceActivator 进行 junit 测试集成流程

在我的 spring-boot 项目中，我有以下课程： @配置 @EnableIntegration 公共类 ConsumeFiles { @豆公共 IntegrationFlow inboundFileFromDirectory(@Value("${pe...

spring-boot junit spring-integration spring-integration-dsl

回答 1 投票 0

Spring Cloud Streams Kafka Binder - 日志处理程序记录完整的有效负载

我正在将 Spring Cloud Streams 与 Kafka Binder 一起使用。我可以看到有效负载被记录为 failedMessage=GenericMessage[payload=[….etc。通过日志处理程序就我而言，我的有效负载包含敏感数据

spring-integration spring-cloud-stream

回答 2 投票 0

Spring 集成 - 支持 SMPP

Spring Integration支持SMPP（短消息点对点）协议吗？查了文档，没有找到专门针对 SMPP 的文档。

spring-integration

回答 1 投票 0

@ServiceActivator(inputChannel = "[topic].[group].errors") 注释会导致“是否存在无法解析的循环引用异常？”

使用处理本地异常的通道时发生异常，但工作正常。 @ServiceActivator(inputChannel = "force-logout-topic.force-logout-group.errors") 公共空间

java spring stream spring-integration

回答 1 投票 0

委托会话工厂 Spring 集成线程安全

我正在使用 Spring Integration 来处理 sftp 会话，我注意到为了使用多个会话并在运行时在它们之间切换，我必须使用 DelegatingSessionFactory 及其方法

java spring-boot spring-integration spring-integration-sftp

回答 1 投票 0

如何在Spring集成中向流程发送消息？

假设以下流程：公共 IntegrationFlow sendFlow() { 返回 IntegrationFlow.from(inputChannel()) .handle("某事","someMethod") ...

java spring spring-integration message-queue endpoint

回答 1 投票 0

具有超时和组大小的聚合需要大量时间

我有这个集成流程 IntegrationFlows.from(MessageChannels.queue(MailPushGateway.SEND_MAIL_NOTIFICATION_CHANNEL, Integer.MAX_VALUE)) .enrichHeaders(headerEnricherSpec ->

spring spring-integration spring-integration-dsl

回答 1 投票 0

Spring 集成 + Micrometer：上下文传播不适用于 DirectChannel

我正在尝试使用千分尺并检测 JPA 存储库并使用 @Observed 对其进行注释。我可以看到周围的跟踪和指标，但是每个方法都会生成一个新的跟踪...

spring-boot spring-integration micrometer spring-micrometer observability

回答 1 投票 0

Spring 集成泄漏

我有一个 Spring 集成应用程序。它基本上有一个带有 requestChannel 的网关，以及一个从通道消费的 @ServiceActivator。 @ServiceActivator 使用轮询器来获取新的

spring memory-leaks spring-integration resource-leak

回答 1 投票 0

使用 sftp 流式入站适配器以块形式流式传输文件

我正在使用 SFTP 流式入站通道适配器，它一次性读取整个文件。它给了我一个输入流，稍后由流转换器转换我想读取文件 dire...

spring spring-boot spring-batch spring-integration

回答 1 投票 0

Spring 集成中的异常处理示例

我正在寻找一个很好的 Spring 集成错误处理示例。我真正想做的就是当这个流程失败时调用一个方法。这个想法是被调用的方法将发出错误 emai...

java spring spring-integration

回答 1 投票 0

接收消息时MessageDeliveryException: Dispatcher没有订阅者

更新：将 fromTcp() 从持有者类移动到端点类后，一切都再次正常工作，现在我很困惑为什么它现在还能工作，因为对我来说，它为什么工作没有意义经过一些

spring-boot spring-integration spring-integration-dsl

回答 1 投票 0

如何在文件适配器的 Spring Integration TaskExecutor 中正确设置线程池和 maxMessagePerPoll 以避免堆问题

我一直遇到两个问题，不知道如何解决。超出 GC 开销限制（堆空间不足，应用程序当前使用 2GB）应用程序暂停 ThreadPoolExecutor 池大小= 50，...

spring-integration

回答 1 投票 0

Spring 集成 - 关闭应用程序时消息队列不为空

假设您正在使用 jdbc-metadata-store 从多个实例（假设有 4 个）轮询一个目录，并且轮询器 maxMessagesPerPoll 设置为 1，间隔为 5 分钟，并且您正在消耗这 m...

spring spring-integration graceful-shutdown spring-integration-file

回答 1 投票 0

构建基于Spring Boot的Webhook消费者服务

我需要构建一个基于 Spring Boot 的 Webhook 服务，该服务可以使用任何格式的 JSON 或 XML 格式的请求主体。例如：我们为已经拥有固定 JSON 的客户提供服务...

spring-boot spring-integration freemarker

回答 1 投票 0

Spring Integration 在 HTTP/2 的“优先级”HTTP 标头验证中失败

随着最近在 Chrome 上推出 Chromium 124，请求标头中引入了新的“优先级”HTTP 标头，默认情况下支持 HTTP/2 和 HTTP/3 协议。更多信息

google-chrome http-headers spring-integration

回答 1 投票 0

spring-integration 相关问题

最新问题