spring-integration 相关问题

这就是我在应用程序中实现 JdbcChannelMessageStore 的方式：这就是我在应用程序中实现 JdbcChannelMessageStore 的方式： <int:transaction-synchronization-factory id="syncFactory"> <int:after-commit expression="@store.removeFromIdCache(headers.id)" /> <int:after-rollback expression="@store.removeFromIdCache(headers.id)"/> </int:transaction-synchronization-factory> <task:executor id="pool" pool-size="10" queue-capacity="10" rejection-policy="CALLER_RUNS" /> <int:channel id="objectToJsonChannelTMF639"> <int:queue message-store="store"/>  </int:channel> <bean id="store" class="org.springframework.integration.jdbc.store.JdbcChannelMessageStore"> <property name="dataSource" ref="dataSource"/> <property name="channelMessageStoreQueryProvider" ref="queryProvider"/> <property name="region" value="CONCURRENT_POLL"/> <property name="usingIdCache" value="true"/> </bean> <int:bridge input-channel="objectToJsonChannelTMF639"> <int:poller fixed-delay="500" receive-timeout="500" max-messages-per-poll="1" task-executor="pool"> <int:transactional propagation="REQUIRED" synchronization-factory="syncFactory" isolation="READ_COMMITTED" transaction-manager="transactionManager" /> </int:poller> </int:bridge> 我在使用 JdbcChannelMessageStore 将数据插入数据库时遇到问题。运行代码时出现以下错误： [2023-08-10 00:08:38,909] 错误 org.springframework.integration.handler.LoggingHandler:250 - ErrorMessage [payload=org.springframework.messaging.MessageDeliveryException: 调度程序没有通道“application.jdbcMessageStoreChannel”的订阅者。 ;嵌套异常是 org.springframework.integration.MessageDispatchingException：调度程序没有订阅者，failedMessage=GenericMessage [payload=CPMPayload [cpmBody=[{"op":"replace","jsonPath":"$.resourceCharacteristic[?(@.name =='AStatus')].value","value":"返回"},{"op":"替换","jsonPath":"$.resourceCharacteristic[?(@.name=='FStatus')] .value","value":"FCredited"},{"op":"替换","jsonPath":"$.resourceCharacteristic[?(@.name=='tmpCPMData_orderId')].value","value" ：“89CJ00”}]，域=逻辑资源，transnSeqId = 44234，externalid = 89CJ00，specName = VideoCpe_LD，externalId = COM-BC743HE1C-1-1，sourceSystem = 3PL-Process，transnSeqId = 44234]，标头= {id = bb7a6bac -7767-5467-490a-c326e780e0ab，时间戳=1691606317062}]，failedMessage=GenericMessage [payload=CPMPPayload [cpmBody=[{"op":"replace","jsonPath":"$.resourceCharacteristic[?(@.name= ='AStatus')].value","value":"返回"},{"op":"替换","jsonPath":"$.resourceCharacteristic[?(@.name=='FStatus')].值","值":"FCredited"},{"op":"替换","jsonPath":"$.resourceCharacteristic[?(@.name=='tmpCPMData_orderId')].value","值": “89CJ00”}]，域=逻辑资源，transnSeqId = 44234，externalid = 89CJ00，specName = VideoCpe_LD，externalId = COM-BC743HE1C-1-1，sourceSystem = 3PL-Process，transnSeqId = 44234]，标头= {id = bb7a6bac- 7767-5467-490a-c326e780e0ab，时间戳=1691606317062}]，标头={id=5458abcc-d97f-5b0f-9278-5525d2663fa8，时间戳=1691606318909}]原始GenericMessage [payload=CPMPayload [cpmBody= [{“操作”： "替换","jsonPath":"$.resourceCharacteristic[?(@.name=='AStatus')].value","值":"返回"},{"op":"替换","jsonPath" :"$.resourceCharacteristic[?(@.name=='FStatus')].value","value":"FCrededited"},{"op":"替换","jsonPath":"$.resourceCharacteristic[? (@.name=='tmpCPMData_orderId')].value","value":"89CJ00"}], 域=逻辑资源, transactionID=44234, externalid=89CJ00, specName=VideoCpe_LD, externalId=COM-BC743HE1C-1-1 ，sourceSystem=3PL-Process，transnSeqId=44234]，标头={id=bb7a6bac-7767-5467-490a-c326e780e0ab，时间戳=1691606317062}] 我面对的是数据库。我观察到我插入数据库的数据在刷新后消失了。提交操作也没有发生，请让我知道这个问题的原因是什么以及如何修复它。您的错误是这样的： Dispatcher has no subscribers for channel 'application.jdbcMessageStoreChannel'. 因此，您的应用程序中有一个 jdbcMessageStoreChannel，您可以在其中尝试发送消息。您没有在问题中显示该配置，但请确保您有该频道的订阅者以使其正常工作。到目前为止您显示的配置与该错误无关。

spring-integration

回答 1 投票 0

Spring 集成：并行处理来自 Sftp.inboundStreamingAdapter 的消息

所以，如果有一个 Spring Integration 5.5 / Spring Boot 2.7 流程，可以从 SFTP 源读取 XML 文件，处理并存储它们，然后删除。事情确实有效，但是是按顺序进行的，这意味着每个文件都是

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

回答 1 投票 0

Spring Integration 分布式锁：与 Redisson 的租用时间相比，TTL 概念上的一致性

这是以下问题的后续问题：https://github.com/spring-projects/spring-integration/issues/8687 正如上面链接中所讨论的，Spring Integration Distributed Lock 的 TTL 概念是为了......

java spring-integration redisson distributed-lock spring-integration-distributed-lock

回答 1 投票 0

如何在 Spring Integration 中使用 JAVA 配置来配置 http 入站通道适配器？

我发现了一个xml配置的入站适配器示例，我不完全理解。该配置指定REST请求设置请求方法、消费格式等。我想从春天开始