Inbound FTP - Polling sub directories

[Gary Russell]

By the way, as Oleg pointed out in post #3 above, you can also use the gateway to fetch files in subdirectories. For example...

	<int-ftp:outbound-gateway id="gatewayLS" cache-sessions="false"
		session-factory="ftpSessionFactory"
		request-channel="inbound"
		command="ls"
		command-options=""
		expression="'a/*/*'"
		reply-channel="toSplitter"/>

	<int:channel id="toSplitter" />

	<int:splitter id="splitter" input-channel="toSplitter" output-channel="toGet"/>

	<int-ftp:outbound-gateway id="gatewayGET" cache-sessions="false"
		local-directory="localdir"
		session-factory="ftpSessionFactory"
		request-channel="toGet"
		reply-channel="toRemoveChannel"
		command="get"
		command-options="-P"
		expression="payload.filename"/>

...fetches all files in all subdirectories of directory "a".

[wemu]

Thanks for the replies!

I found a similar example in the archive: http://forum.springsource.org/archiv.../t-127972.html
But I would prefer not having to go there

I kinda ignored the option using the outbound-gateway. I thought one could not use this to retrieve files. This does preserve the directory structure? There are some issues in Jira that indicate the folder structure is lost.

I'll give the outbound-gateway a try :-)

[Gary Russell]

No, it does, currently, flatten the directory structure,

[wemu]

The namespace doesn't currently support injecting a custom synchronizer; you have to assemble the adapter using <bean/> (or @Bean) definitions.

You need a SourcePollingChannelAdapter, that gets a SftpInboundFileSynchronizingMessageSource in its 'source' property; having passed in your custom synchronizer to the SftpInboundFileSynchronizingMessageSource in its <constructor-arg/>.

For complete details about how to wire up the message source, see AbstractRemoteFileInboundChannelAdapterParser.

So it looks like:

    <bean id="recursiveFtpSynchronizer" class="org.company.sftp.inbound.RecursiveSftpInboundFileSynchronizer">
        <constructor-arg ref="sftpSessionFactory"/>
    </bean>

    <bean id="recursiveFtpMessageSource" class="org.springframework.integration.sftp.inbound.SftpInboundFileSynchronizingMessageSource">
        <constructor-arg ref="recursiveFtpSynchronizer"/>
    </bean>

    <bean class="org.springframework.integration.endpoint.SourcePollingChannelAdapter">
        <property name="source" ref="recursiveFtpMessageSource"/>
    </bean>

all properties from the inbound-channel-adapter namespace are on one of those beans? With less comfort I guess

[Gary Russell]

For the most part, things related to the remote end (session factory etc) go on the synchronizer; things at the local end (local directory etc) go on the MessageSource, although the localFilenameGeneratorExpression goes on the synchronizer. For full details look at the parser.

https://github.com/SpringSource/spri...terParser.java

[wemu]

Thanks for those hints!

I'll give it a try