다양한 하위 디렉토리에서 FTP 서버의 파일을 반복적으로 다운로드

Question

OUTBOUND GATEWAY가있는 인바운드 채널 어댑터를 사용하여 XML 파일에 beans를 구성했습니다. 자바 클래스에서 @serviceactivator를 사용하여 channel.But m 루트 폴더에있는 파일을 가져 오는 하위 디렉터리에서 파일을 가져올 수 없습니다.

내 XML 파일 :

<int:inbound-channel-adapter channel="inbound1" expression="'/'"> 
<int:poller fixed-delay="3000"/> 
</int:inbound-channel-adapter> 

<int-ftp:outbound-gateway id="gatewayGet" 
     session-factory="ftpClientFactory" 
     request-channel="inbound1" 
     local-directory="C:/Users/pprakash/Desktop/DataFiles/actual" 
     auto-startup="true" 
     command="mget" 
     command-options="-R" 
     filename-pattern="*.csv" 
     expression="'actual/*/*'" 
     reply-channel="outbound"/> 

<int:channel id="outbound"> 
<int:interceptors> 
    <int:wire-tap channel="logger"/> 
</int:interceptors> 
</int:channel> 
<int:logging-channel-adapter id="logger" log-full-message="true" /> 

'<bean id="ftpClientFactory" 
        class="org.springframework.integration.ftp.session.DefaultFtpSessionFactory"> 
      <property name="host" value="192.168.79.1"/> 
      <property name="port" value="21"/> 
      <property name="username" value="*****"/> 
      <property name="password" value="*****"/> 
      <property name="bufferSize" value="100000"/> 
</bean>' 

내 자바 코드 같은 것입니다 : -

static int index=0; 
@ServiceActivator(inputChannel = "inbound1") 
public void foo1(File file) throws InterruptedException { 
    logger.debug("Inbound msg to gateway :[ "+(index++)+"]" + file.getAbsolutePath()); 
} 

@ServiceActivator(inputChannel = "outbound") 
public void foo2(List<File> file) throws InterruptedException { 
    System.out.println("outbound gateway"); 
    logger.debug("File Received :[ "+(index++)+"]" + file.size()); 

} 

Answer 1

filename-pattern="*.csv"

귀하의 하위 디렉토리는 또한 스캔되지 않습니다 그 패턴과 일치하지 않는.

는 the documentation

예를 들어, 원격 디렉토리에 1.txt 및 하위 디렉토리 subDir로 끝나는 모든 파일을 검색합니다 참조하십시오. 하위 디렉토리가 필터링 된 경우 해당 하위 디렉토리를 추가로 통과하지 않습니다.

(필자 강조).

그래서 패턴은 트리의 하위 디렉토리를 통과해야합니다.