使用 MessageSessionCallback
從 Spring Integration 4.2 開始,您可以將 MessageSessionCallback<F, T>
實現與 <int-ftp:outbound-gateway/>
(在 Java 中是 FtpOutboundGateway
)一起使用,以便在 requestMessage
上下文下對 Session<FTPFile>
執行任何操作。它可以用於任何非標準或低階 FTP 操作,並允許從整合流定義和函式式介面(Lambda)實現注入中訪問,如下例所示
@Bean
@ServiceActivator(inputChannel = "ftpChannel")
public MessageHandler ftpOutboundGateway(SessionFactory<FTPFile> sessionFactory) {
return new FtpOutboundGateway(sessionFactory,
(session, requestMessage) -> session.list(requestMessage.getPayload()));
}
另一個示例可能是預處理或後處理正在傳送或檢索的檔案資料。
使用 XML 配置時,<int-ftp:outbound-gateway/>
提供 session-callback
屬性,用於指定 MessageSessionCallback
bean 名稱。
session-callback 與 command 和 expression 屬性互斥。使用 Java 配置時,FtpOutboundGateway 類中提供了不同的建構函式。 |