spring-integration 相关问题

为何为何春季领导者选举与JDBClockRepository选举不断尝试插入DB

几年前，我们从某种自我建造的领导人选举机制转变为春季融合领导者选举，均依靠重复的关键违规行为。我们切换到春天

我有一个春季整合流，与JDBCPollingChannelAdapter进行了轮询，因此： IntegrationFlow.from（buildjdbcmessagesource（）， C-> C.Poller（Pol ...

JdbcPollingChannelAdapter

春季SFTP文件在特定时间内进行轮询

如何配置弹簧sftp:inbound-channel-adapter以在特定的计时之间运行，可以说是上午8点至下午7点。 目前，我只有以下配置，我只需要在上午8点至下午7点之间进行轮询 <int:poller fixed-rate="300000" max-messages-per-poll="1" />hear，那个春季批次会有所帮助。有什么建议吗？ please，更具体。用人文描述您的要求。 e.g。您需要每5分钟从上午8点开始进行一次调查，每天晚上7点结束。 在这种情况下，克朗看起来像： 0 0/5 8-19 * * 我有一个场景，我需要每小时与服务器同步一次，而我的消息处理应每5s.进行一次。 I.E。服务器中可用的文件应每小时复制一次，而这些文件应每5 s发送到消息频道并进行处理。 目前，我看到投票程序是耦合的，以同步和发出消息。如何将其解散。我正在使用直接通道。 plays建议

如何使jmx上暴露于jmx的hamismessingrivenChannelAdapter？ 我正在尝试使jmx上暴露于jmx上的运动疗法，以便我可以访问操纵检查点的操作（Rescretchecteckpointforshardtosequendequencenumber等）。但是我所能做的...

spring云流不会将这些通道适配器作为bean揭露到应用程序上下文中。

我正在尝试使用Spring Integration的SMB支持来实现从本地文件系统到远程文件系统的弹簧集成流。 我的春季启动配置如下：

同步的最终结果是预期的，即本地目录中的所有文件均已同步到远程目录并在本地目录中删除。

我有以下2个组件，这些组件应首先从mongo中删除文档，然后从弹性中删除文档。

MessageConversionException：无法转换消息内容

@IntegrationComponentscan注释无法扫描@MessageGateway组件

<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <parent> <groupId>com.sz</groupId> <artifactId>sz-common</artifactId> <version>${revision}</version> </parent> <artifactId>sz-common-mqtt</artifactId> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-integration</artifactId> </dependency> <dependency> <groupId>org.springframework.integration</groupId> <artifactId>spring-integration-mqtt</artifactId> </dependency> <dependency> <groupId>org.eclipse.paho</groupId> <artifactId>org.eclipse.paho.mqttv5.client</artifactId> </dependency> </dependencies> </project>

<code>public IntegrationFlow jiraVersionWebhook() { return IntegrationFlow.from( WebFlux.inboundGateway("/jira/version") .requestMapping(r -> r.methods(HttpMethod.POST) .consumes("application/json")) .requestPayloadType(String.class) .replyChannel(replyChannel) .errorChannel(errorChannel) .mappedRequestHeaders(parameter.getJiraHeaderSignature())) .wireTap(versionQueueChannel()) .get(); } @Bean public QueueChannel versionQueueChannel() { return new QueueChannel(); } @Bean public IntegrationFlow versionFlow() { return IntegrationFlow.from(versionQueueChannel()) .<VersionIssuesConnector>handle((p, h) -> p, e -> e.poller(Pollers.fixedDelay(1000).maxMessagesPerPoll(1)) .handleMessageAdvice(ignoreExceptionRequestHandlerAdvice) .requiresReply(false)) .split(new VersionIssueSplitter()) .handle(longProcess) .aggregate() .get(); } @Bean public MethodInterceptor ignoreExceptionRequestHandlerAdvice() { final var advice = new ExpressionEvaluatingRequestHandlerAdvice(); advice.setTrapException(true); return advice; } </code>

识别春季集成JMS出站适配器写入提交是成功的吗？

在弹簧积分流中，使用SynctasKeexecutor与使用单个螺纹流相同？

<

UnknownHostException：使用 Spring Integration SMB 为 null

我尝试使用 Spring Integration SMB 在 SMB 共享上写入一些文件。我有以下配置： @配置 公共类 SambaConfiguration { @Value("${samba.host}")

动态创建集成流程

我有一个场景，在应用程序运行时通过 IntegrationFlowContext 创建多个集成流（例如，监听 JMS 队列）并且它工作正常（SpringBoot 3.4.0），但是我们注意到......

Spring Integration：聚合器模式 - 下游组件了解组是否完整的一种方式

我们使用 Spring Integration 6.3.3 聚合器模式，带有 JDBCMessageStore 和过期超时。我们还希望在到期时发送部分组，我们将其视为错误条件。我们...

Spring Integration 作为独立 ESB 的嵌入式替代方案

有人有使用 Spring Integration 项目作为嵌入式 ESB 的经验吗？ 我对以下用例非常感兴趣： 按计划从目录中读取文件 从 JDBC 获取数据...

使用多个副本时如何使用 Spring Integration SFTP 正确从 SFTP 服务器获取文件？

目前，我不断收到此错误： org.springframework.messaging.MessagingException 在 org.springframework.integration.endpoint.AbstractPollingEndpoint.pollForMessage(AbstractPollingEndp...

org.springframework.expression.spel.SpelEvaluationException：EL1005E：找不到类型“com.company.package.SomeClass”

注意：我正在使用 Spring Boot 2.2.0.RELEASE，所以它与此无关。 我有一个 MessagingGateway 如下： @网关（ 请求频道 = "我的频道", 标题=@

Spring 集成 - TransactionSynchronizationFactory 中的 TraceId 已更改

TraceId 会发生更改。 调试示例可在 https://github.com/syedyusufh/transaction-sync-traceid 获取 2025-01-05T21:33:21.726...

自定义注释在 Spring Beans 上不起作用

我创建了新的自定义注释@MyCustomAnnotation： @Target({ElementType.METHOD, ElementType.TYPE, ElementType.FIELD}) @Retention（运行时） 公共@interface MyCustomAnnotation { } 我申请了

我们可以混合企业集成模式和六边形架构吗

尝试了解我们如何将六边形架构与 EIP 结合使用。 在下面的 Spring Boot 示例中，UserMessageHandler 是入站适配器的一部分（根据我的说法），并且被调用...