如何在 ftp 出站网关中进行 mput 操作后获取文件列表？
我设法将文件从本地 ftp 传输到远程 ftp。现在，我想要所涉及的路径和文件的列表，以便我可以对其应用逻辑，例如将新行插入数据库。据说 mput 操作产…
由 Spring Integration 触发时，Spring Batch 失败并出现事务错误
我有一个简单的 Spring Boot (2.6.4) 应用程序，它使用 Spring Batch 和 Spring Integration 从文件读取数据并发出 Kafka 事件。我已将 Spring Integr…
Spring 集成解组
我正在尝试使用 UnmarshallingTransformer 在 Spring 集成中将 java 对象解组为 xml，但收到错误消息，表明未创建有效负载。 这是我的代码： @Bean pu…
Spring Integration 子流程取决于 .handle 方法
我正在使用 spring 集成在特定重试完成后更改流程。我的 errorResponse 的 IntegrationFlow bean 如下： @Bean public IntegrationFlow errorMailResp…
如何在 spring-integration 中计算传输文件的校验和/摘要
如何/在哪里计算我需要传输到 spring-integration 中的 samba 位置的文件的 md5 摘要，以便根据我在流程开始时收到的摘要来验证它。我从休息服务获取…
我可以在 TcpOutBoundgateway 上将 RemoteTimeOut 设置为无限吗
我正在使用 CachingClientConnectionFactory，如何保持连接处于活动状态，在默认的 RemoteTimeOut 经过后关闭连接，我可以将 RemoteTimeOut 设置为 LO…
响应式 Spring Data Mongo 合并操作
我想使用 Spring Integration 和 Project Reactor 写入 MongoDB。我需要的命令是合并操作，所以我从以下代码片段开始： MergeOperation mergeOperatio…
spring kafka 入站和出站映射头不同
我们正在使用 spring-kafka，对于与我们通信但未设置 spring_json_header_types 标头的非 spring 应用程序，我们指定某些标头应通过将它们添加为 rawM…
将java对象转换为xml
如何将java对象转换为xml？我正在尝试在 Spring 与转换器 bean 集成中将传入的 java 对象转换为 xml。除了 Jaxb 中的编组之外还有其他方法吗？就像使…
如何传递多个动态标头和请求正文以在 Spring 集成中进行休息调用
MyGateway（在服务接口中定义）是一个接口，将包含一个请求正文（JsonFormat），我将在 http-outbound-gateway 中将其传递给其余调用
如何从 TcpConnectionFactory 重新打开 Spring Socket？
@Bean public TcpConnectionFactoryFactoryBean tcpFactory(LengthHeaderDeserializer deserializer) throws Exception { TcpConnectionFactoryFactor…
Spring 集成中的 Marshaller
我正在尝试在 spring 集成中将 java 对象编组为 xml。我尝试使用新的 MarshallingTransformer。但我不知道如何将编组器传递给它。 这是我的代码： ret…
Spring集成电子邮件pop3入站适配器不工作/启动
使用java spring集成编写了以下代码来从gmail读取电子邮件。 根据日志，似乎与 gmail 的连接已形成，但在新电子邮件上，它不读取或不进入 handle() 方…
为什么要“有序停工”不停止可轮询消息源？
我很难理解为什么 IntegrationMBeanExporter.stopActiveComponents 方法不负责停止轮询器，如下所示。 在调用 stopActiveComponents 后不停止下面的集…
