有关Spring Integration项目的问题，请使用此标记。它不适用于将其他Spring项目与其他技术集成的一般问题。
我们需要监听端口并接收消息，然后我们需要将其写回到同一个输出流中。我们已经编写了运行良好的自定义解串器。但自定义序列化器我...
检查 Spring Integretion FTP 中的被动端口
https://medium.com/nerd-for-tech/retrieve-files-from-ftp-server-using-spring-integration-5ccc4a972eaf 我正在基于上述站点实现 FTP 行为。 在上面的网站中，我只添加了...
Spring Integration - 回滚 JMS MessageDrivenChannelAdapter 而不会造成日志污染
我正在使用 Spring Integration（带有 Java DSL）来使用来自 JMS（MQ 和 Solace）的消息。 在某些情况下，我的流程会引发异常，我希望将消息回滚到传输并重新返回...
我目前正在学习 spring-batch-integration，为此我想创建一个应用程序来监视指定目录中的 txt 文件，然后如果该文件存在则启动批处理作业...
我对 Spring 集成以及下面所述的几乎所有内容都是新手。 我有一个 inboundChannelAdapter 来从 pubsub 中的订阅中提取消息。 事实上，它正在从 p 中提取消息...
如何处理 SI HttpRequestExecutingMessageHandler 中的“Transfer-Encoding=chunked”
我正在使用 HttpRequestExecutingMessageHandler 调用外部服务器。我正在使用 JSON 到对象转换器来转换 JSON 数据。但我收到以下异常。 引起者：com.
如何使用 Spring 集成将请求方法从 POST 更改为 GET 并从正文请求参数中提取？
我有一个正在运行的 api，它需要 prop 作为参数。我想解决的任务是使用 spring 集成创建一个代理，该代理接受带有 body 的 post 请求。例如： 发布http://
当文件对象是目录时，如何将 SFTP Spring Integration mput 与 SftpOutboundGateway 一起使用？
<int-sftp:outbound-gateway session-factory="sftpSessionFactory" use-temporary-file-name="false" request-channel="tmpDirToUploadOutputChannel" command="mput" expression="payload" remote-directory="/out" reply-channel="sftpUploadFilesResultChannel"> </int-sftp:outbound-gateway>` 当我从服务激活器发送消息时 - 文件是包含文件的目录 val message = MessageBuilder .withPayload(tmpOutFile) // .setHeader("file_name", tmpOutFileName) .build() 出站网关使用最后一个文件名，在服务器上我只能看到服务器上的一个文件 如何正确使用并使用所有文件名？ 我来自服务激活器的消息 尤里卡！ inbound-channel-adapter --> service-activator 返回消息文件是目录 --> sftp outbound-gateway sftp 出站网关将来自入站通道适配器的文件名缓存在标头 file_name 中 当我设置“file_name”时，“” val message = MessageBuilder .withPayload(File(tmpOutDirPath)) .setHeader("file_name", "") .build() 在这种情况下，removeHeader 也不起作用
如何在Spring集成中使用rabbitmq作为缓冲区来创建背压缓解？
我有一个在 http://localhost:9999/greet/v3/api (API A) 上运行的 api，它响应 2 秒延迟的请求（模拟）。我创建了以下集成流程来代理所有
我想评估一下spring集成是否适合我们当前的需求。 我们将收到一个包含 100 万笔交易的输入流（让我们考虑下面代码中的 A 是 1
Spring Integration 反序列化器未通过 TCP 获取整个消息
我们正在使用 Spring 集成流连接到 Tcp 端口并获取消息。 在下面找到相同的代码。 @豆 公共集成流集成流（）{ 返回
我正在使用 stomp 从 ruby 脚本将 XML 内容发送到 ActiveMQ 我将内容类型标头显式设置为 application/xml;charset=utf-8 ，如下所示 client.publish 队列，xml，{'content-
Spring Integration JMS 出站适配器事务控制
为了在启用事务的情况下使用 jms 实现消息的高性能生产，需要控制每个事务发送的消息量，h 的数字越大...
原因：com.jcraft.jsch.JSchException：使用 sftp 私钥进行身份验证失败
<bean id="sftpSessionFactory" class="org.springframework.integration.sftp.session.DefaultSftpSessionFactory"> <property name="host" value="${host}" /> <property name="privateKey" value="file:${keyfile}"/> <property name="user" value="${user}" /> <property name="port" value="${port}" /> </bean> 我有上面的配置。我在服务器上的授权密钥 ~/.ssh2 下有公钥。我仍然收到 Caused by: com.jcraft.jsch.JSchException: Auth failed 错误。所有凭据均正确，并且能够通过命令提示符进行 sftp。请尽快建议。使困惑。 请查看日志： 信息 | JVM 1 | 2014/10/31 13:41:23 | ... 21 更多 信息| JVM 1 | 2014/10/31 13:41:23 |原因：com.jcraft.jsch.JSchException：身份验证失败 信息| JVM 1 | 2014/10/31 13:41:23 |在 com.jcraft.jsch.Session.connect(Session.java:464) 信息| JVM 1 | 2014/10/31 13:41:23 |在 com.jcraft.jsch.Session.connect(Session.java:158) 信息| JVM 1 | 2014/10/31 13:41:23 |在 org.springframework.integration.sftp.session.SftpSession.connect(SftpSession.java:198) 信息| JVM 1 | 2014/10/31 13:41:23 | ... 22 更多 这是详细日志。我很困惑是否正在连接。你能帮我吗 对于未来的读者： 按照参考手册中的讨论，打开 JSCH 的 DEBUG 日志记录。它应该可以帮助您追踪它。
增加 Paho MQTT java 客户端上的最大飞行数量有什么缺点吗？
我正在使用 Spring Integration MQTT，它使用 Eclipse Paho 客户端将 MQTT 消息发送到 ActiveMQ Artemis 服务器。在我的应用程序上运行性能测试时，我收到“太多
多个测试应用程序上下文侦听竞争消费者队列会导致间歇性测试失败
我正在测试一个 JMSInboundGateway，它监听 Apache Artemis 队列（竞争消费者）。我的测试向 Artemis 服务器发送一条消息并模拟目标服务。如果...
问题陈述： 我正在将我的应用程序从 Spring 5.x 重构为 Spring 6.0.0 。 由于 Oracle 对 java API 的更改，一些依赖项被迫更改。 有一个...
我们使用以下方式混合 spring-integration 和 spring-boot 的调度功能： @SpringBootApplication @EnableIntegration @IntegrationComponentScan @EnableConfigurationProperties @
Spring Integration - 获取入站网关响应的警告日志，然后继续在后台进行异步处理
说明： 我们有一个 Spring 集成流程，我们想要配置一个端点，分割有效负载，并行执行一些转换，然后在经过一些验证后返回一部分......
我有一个 Spring Integration 流程，它使用 Jpa.inboundAdapter() 作为源，在转换中操作读取的实体，最后使用 Jpa.outboundAdapter 再次存储它们。 然而，在人...