Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

INT-1614 removed the 'remotePredicate' from the MessageSource, it is defined on the synchronizer

Browse Source
This commit is contained in:
Mark Fisher
2010-11-21 23:24:14 -05:00
parent deccbc5c08
commit d1e45f79e0
2 changed files with 2 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
spring-integration-file/src/main/java/org/springframework/integration/file/remote/synchronizer/AbstractInboundFileSynchronizingMessageSource.java
View File

@@ -75,11 +75,6 @@ public abstract class AbstractInboundFileSynchronizingMessageSource<F> extends M
*/
protected volatile FileReadingMessageSource fileSource;
/**
* The predicate to use in scanning the remote File system for downloads.
*/
protected FileListFilter<F> remotePredicate;
public void setAutoCreateDirectories(boolean autoCreateDirectories) {
this.autoCreateDirectories = autoCreateDirectories;
@@ -93,16 +88,9 @@ public abstract class AbstractInboundFileSynchronizingMessageSource<F> extends M
this.localDirectory = localDirectory;
}
public void setRemotePredicate(FileListFilter<F> remotePredicate) {
this.remotePredicate = remotePredicate;
}
@Override
protected void onInit() {
try {
if (this.remotePredicate != null) {
this.synchronizer.setFilter(this.remotePredicate);
}
if (this.localDirectory != null && !this.localDirectory.exists()) {
if (this.autoCreateDirectories) {
if (logger.isDebugEnabled()) {
@@ -115,9 +103,7 @@ public abstract class AbstractInboundFileSynchronizingMessageSource<F> extends M
}
}
/**
* Forwards files once they ultimately appear in the {@link #localDirectory}.
*/
// Forwards files once they ultimately appear in the {@link #localDirectory}.
this.fileSource = new FileReadingMessageSource();
this.fileSource.setFilter(this.buildFilter());
this.fileSource.setDirectory(this.localDirectory);

2
spring-integration-sftp/src/main/java/org/springframework/integration/sftp/inbound/SftpInboundFileSynchronizer.java
View File

@@ -29,7 +29,7 @@ import com.jcraft.jsch.ChannelSftp.LsEntry;
* @author Mark Fisher
* @since 2.0
*/
public class SftpInboundFileSynchronizer extends AbstractInboundFileSynchronizer<LsEntry> {
class SftpInboundFileSynchronizer extends AbstractInboundFileSynchronizer<LsEntry> {
public SftpInboundFileSynchronizer(SessionFactory sessionFactory) {
super(sessionFactory);