跳到主要内容

MessageSessionCallback

QWen Plus 中英对照 MessageSessionCallback

从 Spring Integration 4.2 版本开始,您可以使用 MessageSessionCallback<F, T> 实现与 <int-sftp:outbound-gateway/> (SftpOutboundGateway) 一起使用,在 Session<SftpClient.DirEntry> 上执行任何带有 requestMessage 上下文的操作。您可以将其用于任何非标准或低级别的 SFTP 操作(或多个操作),例如允许从集成流定义或函数式接口(lambda)实现注入访问。以下示例使用了 lambda:

@Bean
@ServiceActivator(inputChannel = "sftpChannel")
public MessageHandler sftpOutboundGateway(SessionFactory<SftpClient.DirEntry> sessionFactory) {
return new SftpOutboundGateway(sessionFactory,
(session, requestMessage) -> session.list(requestMessage.getPayload()));
}
java

另一个例子可能是对发送或检索的文件数据进行预处理或后处理。

当使用 XML 配置时,<int-sftp:outbound-gateway/> 提供了一个 session-callback 属性,可以让您指定 MessageSessionCallback bean 名称。

备注

session-callbackcommandexpression 属性是互斥的。在使用 Java 配置时,SftpOutboundGateway 类提供了不同的构造函数。