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

removig old SftMessageSource

Browse Source
This commit is contained in:
Josh Long
2010-08-20 23:13:20 +00:00
parent 7a15cabfe2
commit 3e79a551cc
1 changed files with 0 additions and 140 deletions
Download Patch File Download Diff File Expand all files Collapse all files

140
spring-integration-sftp/src/main/java/org/springframework/integration/sftp/SftpMessageSource.java
View File

@@ -1,140 +0,0 @@
/*
* Copyright 2010 the original author or authors
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.springframework.integration.sftp;
import com.jcraft.jsch.ChannelSftp;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.context.Lifecycle;
import org.springframework.core.io.Resource;
import org.springframework.integration.Message;
import org.springframework.integration.core.MessageSource;
import org.springframework.integration.file.FileReadingMessageSource;
import org.springframework.integration.file.entries.CompositeEntryListFilter;
import org.springframework.integration.file.entries.PatternMatchingEntryListFilter;
import org.springframework.scheduling.TaskScheduler;
import org.springframework.scheduling.Trigger;
import java.io.File;
import java.io.IOException;
import java.util.regex.Pattern;
/**
* this creates the message source that ultimately 'see's files on a local directory and forwards them on to the bus.
* These files are asynchronously deposited into a folder via the SFTP synchronizer. This code is <i>very</i> influenced
* by the FtpFileSource class from the Spring Integration FTP adapter.
*
* @author Josh Long
*/
public class SftpMessageSource implements MessageSource<File>, InitializingBean, Lifecycle {
private FileReadingMessageSource fileReadingMessageSource;
private Resource localDirectory;
private SftpInboundSynchronizer synchronizer;
private TaskScheduler taskScheduler;
private Trigger trigger;
private SftpEntryNamer lsEntryEntryNamer = new SftpEntryNamer();
public SftpMessageSource(FileReadingMessageSource fileSource, SftpInboundSynchronizer synchronizer) {
this.fileReadingMessageSource = fileSource;
this.synchronizer = synchronizer;
Pattern completePattern = Pattern.compile("^.*(?<!" + SftpInboundSynchronizer.INCOMPLETE_EXTENSION + ")$");
PatternMatchingEntryListFilter<ChannelSftp.LsEntry> filePatternMatchingEntryListFilter = new PatternMatchingEntryListFilter<ChannelSftp.LsEntry>(lsEntryEntryNamer, completePattern);
PatternMatchingEntryListFilter<ChannelSftp.LsEntry> lsEntryPatternMatchingEntryListFilter = new PatternMatchingEntryListFilter<ChannelSftp.LsEntry>(this.lsEntryEntryNamer, completePattern);
CompositeEntryListFilter<ChannelSftp.LsEntry> fileCompositeEntryListFilter = new CompositeEntryListFilter<ChannelSftp.LsEntry>(filePatternMatchingEntryListFilter,
lsEntryPatternMatchingEntryListFilter);
// todo this.fileReadingMessageSource.setFilter( fileCompositeEntryListFilter);
//fileReadingMessageSource.setFilter( (completePattern)));
}
public void afterPropertiesSet() throws Exception {
synchronizer.afterPropertiesSet();
this.fileReadingMessageSource.afterPropertiesSet();
}
public FileReadingMessageSource getFileReadingMessageSource() {
return fileReadingMessageSource;
}
public Resource getLocalDirectory() {
return localDirectory;
}
public SftpInboundSynchronizer getSynchronizer() {
return synchronizer;
}
public TaskScheduler getTaskScheduler() {
return taskScheduler;
}
public Trigger getTrigger() {
return trigger;
}
public boolean isRunning() {
return this.synchronizer.isRunning();
}
public Message<File> receive() {
return this.fileReadingMessageSource.receive();
}
public void setFileReadingMessageSource(final FileReadingMessageSource fileReadingMessageSource) {
this.fileReadingMessageSource = fileReadingMessageSource;
}
public void setLocalDirectory(final Resource localDirectory) {
this.localDirectory = localDirectory;
try {
this.fileReadingMessageSource.setDirectory(localDirectory.getFile());
} catch (IOException e) {
}
this.synchronizer.setLocalDirectory(localDirectory);
}
public void setSynchronizer(final SftpInboundSynchronizer synchronizer) {
this.synchronizer = synchronizer;
}
public void setTaskScheduler(final TaskScheduler taskScheduler) {
this.taskScheduler = taskScheduler;
synchronizer.setTaskScheduler(taskScheduler);
}
public void setTrigger(final Trigger trigger) {
this.trigger = trigger;
this.synchronizer.setTrigger(trigger);
}
public void start() {
synchronizer.start();
}
public void stop() {
synchronizer.stop();
}
}