Apache Camel-如何在dinamic sftpendpoint中设置私钥

Question

使用Java DSL，我有一个路由，其中我使用消息头中设置的文件名轮询SFTP服务器中的文件

from("direct:download")
        .pollEnrich()
        .simple("sftp://my.host:22/folder/?username=foo&fileName=${header.CamelFileName}")
        .to("file://state/downloaded");

        endpoint("sftp://my.host:22/folder/?username=foo&fileName=my_file_explicitly_written_here", SftpEndpoint.class).getConfiguration().setPrivateKey(getSshPrivateKey());

对此有什么建议吗？

Answer 1

您可以引用privatekey作为注册表中的bean。

.pollEnrich()
    .simple("sftp://my.host:22/folder/?username=foo&privateKey=#myKeyInRegistry&fileName=${header.CamelFileName}")

将bean绑定到注册表取决于您使用的平台和Camel版本。