spring-integration 相关问题

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

原因: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 日志记录。它应该可以帮助您追踪它。

回答 1 投票 0

增加 Paho MQTT java 客户端上的最大飞行数量有什么缺点吗?

我正在使用 Spring Integration MQTT,它使用 Eclipse Paho 客户端将 MQTT 消息发送到 ActiveMQ Artemis 服务器。在我的应用程序上运行性能测试时,我收到“太多

回答 1 投票 0

多个测试应用程序上下文侦听竞争消费者队列会导致间歇性测试失败

我正在测试一个 JMSInboundGateway,它监听 Apache Artemis 队列(竞争消费者)。我的测试向 Artemis 服务器发送一条消息并模拟目标服务。如果...

回答 1 投票 0

Spring Artemis 依赖冲突 - 如何解决

问题陈述: 我正在将我的应用程序从 Spring 5.x 重构为 Spring 6.0.0 。 由于 Oracle 对 java API 的更改,一些依赖项被迫更改。 有一个...

回答 1 投票 0

混合 Spring 集成和 Spring 调度程序

我们使用以下方式混合 spring-integration 和 spring-boot 的调度功能: @SpringBootApplication @EnableIntegration @IntegrationComponentScan @EnableConfigurationProperties @

回答 2 投票 0

Spring Integration - 获取入站网关响应的警告日志,然后继续在后台进行异步处理

说明: 我们有一个 Spring 集成流程,我们想要配置一个端点,分割有效负载,并行执行一些转换,然后在经过一些验证后返回一部分......

回答 1 投票 0

Spring 集成:Jpa 出站适配器的错误处理

我有一个 Spring Integration 流程,它使用 Jpa.inboundAdapter() 作为源,在转换中操作读取的实体,最后使用 Jpa.outboundAdapter 再次存储它们。 然而,在人...

回答 1 投票 0

Spring 集成错误:上传文件时无法写入“foo/002.txt.writing”

我正在试验 SI 示例中的以下示例设置,以了解其内部工作原理,目标是使其适应上层环境中的类似任务集。 DailyCashReport应用...

回答 1 投票 0

Spring Integration 文件分割示例不会对进入入站适配器通道的内容做出反应

我正在测试 SI 示例中的以下示例设置,以了解并使其适应类似的任务集。我不需要邮件功能,但其余部分似乎适应性足够......

回答 1 投票 0

spring 集成轮询器与调度程序

我正在尝试使用 spring 集成设置一个简单的应用程序。目标是简单地使用文件入站通道适配器来监视新文件的目录并在添加文件时处理文件...

回答 1 投票 0

Spring Integration 中的跟踪(Spring boot 3.0.9)

我正在尝试使用 Spring 集成:我通过 JMS 收到一条消息并将其发送到 Kafka: @覆盖 受保护的 IntegrationFlowDefinition buildFlow() { 从(Jms.

回答 1 投票 0

多个 ThreadStatePropagationChannelInterceptors 不可能

我有一个 Spring Integration 设置,其中配置了一个 SecurityContextPropagationChannelInterceptor,它传播 spring 安全上下文异步通道边界。这效果很好。 我也

回答 1 投票 0

Spring Integration 文件轮询器事务中的新事务范围

我们有一个受pseudoTransactionManager限制的文件轮询器流,用于在处理结束时根据成功或失败移动/删除输入文件。在处理这个巨大的文件时,我们会...

回答 1 投票 0

使用 kafka 扩展 Spring Batch 远程分区

我需要通过使用kafka进行远程分区来扩展spring批处理作业。 我想在一台虚拟机上运行管理器步骤,在不同的虚拟机上运行工作器步骤。为此我有一些问题—— 如果我的管理器 VM 实例

回答 1 投票 0

Spring 集成:将 Web 服务挂接到 FIFO 队列

我仍在与 Spring Integration 作斗争 - 这是我的场景: Web 服务收到来自客户端 A 的请求 Web 服务将请求放入队列 队列消费者处理消息 FIFO ...

回答 5 投票 0

imap 邮件接收器

我正在使用 Spring Boot 2.2.4-RELEASE 和 Spring Integration 5.2.3,并且我正在使用 IntegrationFlow 和 DSL,因为我需要配置多个 IMAP 服务器。 所以我写了这段代码: 字符串流 ID =

回答 1 投票 0

如何向kafka发布IntegrationFlow添加重试建议

如果在我的publisherFlow 中发布到kafka 时出现错误,我正在尝试设置retryAdvice。我似乎无法找到如何让它工作的正确配置。任何帮助或指导都会

回答 1 投票 0

如何在 Spring Integration 中并行处理多个进程中的消息,同时必须在相关 ID 上顺序处理消息

具有多个进程的集群必须在接收时间顺序处理同一相关 ID 的消息。对于不同的相关 ID,必须并行处理它们。如何解决这个问题

回答 1 投票 0

使用SftpRemoteFileTemplate从远程服务器删除文件

我正在尝试使用 SftpRemoteFileTemplate 处理文件并将其放在 kafka 主题上后删除该文件。我使用 SftpOutboundGateway 让它工作,但根据 EIS 模式,我们...

回答 1 投票 0

Spring Integration Mono<?> 或 CompletableFuture<?> 与 async false

我们如何在 Spring Integration 5.x 中使用 Mono 或 CompletableFuture 实现相当于 ListenableFuture async=false 的效果? 我们有很多反应式处理程序(服务激活器模式)...

回答 1 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.