MessageSessionCallback
从 Spring Integration 版本 4.2 开始,你可以使用 <int-sftp:outbound-gateway/>
(SftpOutboundGateway
) 中的 MessageSessionCallback<F, T>
实现,在具有 requestMessage
上下文的 Session<SftpClient.DirEntry>
上执行任何操作。你可以将其用于任何非标准或底层 SFTP 操作(或多个操作),例如允许从集成流定义或函数式接口(lambda)实现注入中进行访问。以下示例使用 lambda:
@Bean
@ServiceActivator(inputChannel = "sftpChannel")
public MessageHandler sftpOutboundGateway(SessionFactory<SftpClient.DirEntry> sessionFactory) {
return new SftpOutboundGateway(sessionFactory,
(session, requestMessage) -> session.list(requestMessage.getPayload()));
}
另一个示例可能是预处理或后处理正在发送或检索的文件数据。
在使用 XML 配置时,<int-sftp:outbound-gateway/>
提供了一个 session-callback
属性,可让您指定 MessageSessionCallback
bean 名称。
|