Spring統合の古いローカルファイルを置き換える方法FTPインバウンドチャネルアダプタ

Question

リモートFTPにファイルがあります。たとえば、 "abc.txt"です。このファイルは1分ごとに更新されます。同じファイルを1分ごとに取得するようにFTP Inbound Channel Adapterを設定しました。

これは初めて正常に動作します（つまり、ローカルディレクトリはまだ空です）。ただし、2回目以降の中間ファイルabc.txt.writingは、元のabc.txtファイルを置き換えることはできません。つまり、abc.txt（旧バージョン）とabc.txt.writingの両方が同じディレクトリに共存することになります。 （新しいバージョンのデータ）。 （エラープロンプトなし）

私はバグを打つか、古いバージョンのファイルを最初に削除してabc.txt.writingが正常に名前を変更できるようにパラメータを設定する必要があります。 FileWritingMessageHandler

<bean id="ftpSessionFactory" 
     class="org.springframework.integration.ftp.session.DefaultFtpSessionFactory" 
     p:host="127.0.0.1" 
     p:port="21" 
     p:username="myusername" 
     p:password="mypassword"> 

<bean id="cachingSessionFactory" class="org.springframework.integration.file.remote.session.CachingSessionFactory"> 
     <constructor-arg ref="ftpSessionFactory" /> 
     <constructor-arg value="1" /> 
     <property name="sessionWaitTimeout" value="1000" /> 
</bean> 

<int-ftp:inbound-channel-adapter id="myChannel" 
            channel="nullChannel" 
            session-factory="cachingSessionFactory" 
            filename-pattern="abc.txt" 
            remote-directory="/" 
            preserve-timestamp="true" 
            local-directory="c:/temp"> 
    <int:poller cron="15 * * * * ?" max-messages-per-poll="1" /> 
</int-ftp:inbound-channel-adapter> 



c:\temp> dir /a 
06/23/2017 11:44 AM   840,000 abc.txt 
06/23/2017 11:45 AM   840,000 abc.txt.writing 

Answer 1

は、デフォルトではfalseあるdeleteSourceFilesオプションがあります。これは、<int-file:outbound-channel-adapter>を使用する場合です。

どういうわけか他の方法でローカルファイルを処理するとします。 <service-activator>、あなたはExpressionEvaluatingRequestHandlerAdviceを使用し、成功時にFile.delete()を実行するために検討する必要があります。

<int:request-handler-advice-chain> 
     <bean class="org.springframework.integration.handler.advice.ExpressionEvaluatingRequestHandlerAdvice"> 
      <property name="onSuccessExpressionString" value="payload.delete()"/> 
     </bean> 
    </int:request-handler-advice-chain> 

その​​が正確<int-ftp:inbound-channel-adapter>の結果としてFile地元であるところ。