我一直在研究 spring 集成<int-ftp:outbound-gateway>，我可以从远程服务器下载文件ftp-outbound-gateway，但是有一个问题我还没有解决，如果远程目录包含文件，系统可以正常工作并且可以完成没有任何问题，但是如果没有文件系统挂起而没有从那时起执行。我想继续系统。远程文件夹是否包含文件，
这是我的 ftp 下载配置
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:int="http://www.springframework.org/schema/integration"
xmlns:p="http://www.springframework.org/schema/p"
xmlns:int-ftp="http://www.springframework.org/schema/integration/ftp"
xsi:schemaLocation="http://www.springframework.org/schema/integration/ftp
http://www.springframework.org/schema/integration/ftp/spring-integration-ftp.xsd
http://www.springframework.org/schema/integration
http://www.springframework.org/schema/integration/spring-integration.xsd
http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context.xsd">
<context:property-placeholder location="classpath:host.properties"/>
<int:gateway id="gw" service-interface="com.util.ToFtpFlowGateway"
default-request-channel="inbound"/>
<bean id="downloadProcessBean" class="com.util.FTPDownloadInterceptor">
<property name="fileType" value="txt"/>
<property name="sourceType" value="ftp"/>
<property name="destinationName" value="destinationName"/>
<property name="destinationQueName" value="destinationQueName"/>
<property name="sourceAddressDetails" value="sourceAddressDetails"/>
<property name="sourceName" value="sourceName"/>
</bean>
<bean id="ftpSessionFactory"
class="org.springframework.integration.ftp.session.DefaultFtpSessionFactory">
<property name="host" value="${local.host}"/>
<property name="port" value="${local.availableServerPort}"/>
<property name="username" value="${local.userid}"/>
<property name="password" value="${local.user.password}"/>
</bean>
<int-ftp:outbound-gateway id="gatewayLS" cache-sessions="false"
session-factory="ftpSessionFactory"
request-channel="inbound"
command="ls"
command-options=""
expression="payload"
reply-channel="toSplitter" reply-timeout="10" />
<int:channel id="toSplitter">
<int:interceptors>
<int:wire-tap channel="logger"/>
</int:interceptors>
</int:channel>
<int:logging-channel-adapter id="logger" log-full-message="true" />
<int:splitter id="splitter" input-channel="toSplitter" output-channel="toGet"/>
<int-ftp:outbound-gateway id="gatewayGET" cache-sessions="false"
local-directory="/home/udeshika/project/req/local/download"
session-factory="ftpSessionFactory"
request-channel="toGet"
reply-channel="toRemoveChannel"
command="get"
command-options="-P"
expression="payload.remoteDirectory + '/' + payload.filename" reply-timeout="10"/>
<int-ftp:outbound-gateway id="gatewayRM"
session-factory="ftpSessionFactory" cache-sessions="false"
expression="payload.remoteDirectory + '/'+ payload.filename"
request-channel="toRemoveChannel"
command="rm"
reply-channel="aggregateResultsChannel"
auto-create-local-directory="true"
reply-timeout="10"
/>
<!--<bean id="fileDownloadIntecepter" class="shipxpress.util.FTPDownloadInterceptor"/>-->
<int:channel id="toRemoveChannel">
<int:interceptors>
<int:wire-tap channel="logger2"/>
<!--<int:ref bean="fileDownloadIntecepter" />-->
</int:interceptors>
</int:channel>
<bean class="org.springframework.integration.file.FileReadingMessageSource"
p:directory="${download.directory}"/>
<int:logging-channel-adapter id="logger2" log-full-message="true" />
<int-ftp:outbound-gateway id="gatewayRM"
session-factory="ftpSessionFactory" cache-sessions="false"
expression="headers['file_remoteDirectory'] + '/' + headers['file_remoteFile']"
request-channel="toRemoveChannel"
command="rm"
reply-channel="aggregateResultsChannel"/>
<int:aggregator input-channel="aggregateResultsChannel"/>
</beans>
谁能帮我清除这个，
提前谢谢你Udeshika，