彈簧集成 - 文件：入站通道適配器 - 刪除原始文件

Question

我有一個文件：入站通道適配器輪詢目錄的文件，然後通過SFTP發送到服務器。上傳之後（工作正常），原始文件需要被刪除;如何在上傳後刪除原始文件？ 在文件：出站通道適配器中，我可以設置一個屬性來自動解碼文件。

<file:inbound-channel-adapter 
    id="incomingFiles"  
    channel="myFiles"  
    directory="file:/tmp/kots"> 
    <int:poller id="poller" fixed-delay="1000"/> 
</file:inbound-channel-adapter> 

<int:channel id="myFiles"/> 

.... 

<sftp:outbound-channel-adapter 
    id="sftpOutboundAdapter" 
    channel="myFiles" 
    charset="UTF-8"  
    remote-directory="/tmp/testing"  
    session-factory="sftpSessionFactory"/> 

Answer 1

Transaction Synchronization是你：

<file:inbound-channel-adapter 
    id="incomingFiles"  
    channel="myFiles"  
    directory="file:/tmp/kots"> 
    <int:poller id="poller" fixed-delay="1000"> 
     <int:transactional transaction-manager="transactionManager" synchronization-factory="syncFactory" /> 
    </int:poller> 
</file:inbound-channel-adapter> 


<int:transaction-synchronization-factory id="syncFactory"> 
    <int:after-commit expression="payload.delete()" channel="nullChannel"/> 
</int:transaction-synchronization-factory> 

凡transactionManager可能是從開箱org.springframework.integration.transaction.PseudoTransactionManager。