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

FileNameGenerator is now configurable for FileSourceAdapter and FileTargetAdapter.

Browse Source
This commit is contained in:
Mark Fisher
2008-01-03 03:33:16 +00:00
parent 4404d5a260
commit a022225aed
3 changed files with 22 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
spring-integration-core/src/main/java/org/springframework/integration/adapter/DefaultTargetAdapter.java
View File

@@ -69,6 +69,10 @@ public class DefaultTargetAdapter implements TargetAdapter {
this.mapper = mapper;
}
protected MessageMapper getMessageMapper() {
return this.mapper;
}
public void setConsumerPolicy(ConsumerPolicy policy) {
Assert.notNull(policy, "'policy' must not be null");
this.policy = policy;

8
spring-integration-core/src/main/java/org/springframework/integration/adapter/file/FileSourceAdapter.java
View File

@@ -46,6 +46,14 @@ public class FileSourceAdapter extends PollingSourceAdapter<File> {
}
}
public void setFileNameGenerator(FileNameGenerator fileNameGenerator) {
Assert.notNull(fileNameGenerator, "'fileNameGenerator' must not be null");
MessageMapper<?,?> mapper = this.getMessageMapper();
if (mapper instanceof AbstractFileMapper<?>) {
((AbstractFileMapper<?>) mapper).setFileNameGenerator(fileNameGenerator);
}
}
public void setBackupDirectory(File backupDirectory) {
Assert.notNull(backupDirectory, "'backupDirectory' must not be null");
MessageMapper<?, File> mapper = this.getMessageMapper();

10
spring-integration-core/src/main/java/org/springframework/integration/adapter/file/FileTargetAdapter.java
View File

@@ -20,6 +20,8 @@ import java.io.File;
import org.springframework.integration.adapter.DefaultTargetAdapter;
import org.springframework.integration.adapter.Target;
import org.springframework.integration.message.MessageMapper;
import org.springframework.util.Assert;
/**
* A convenience adapter for writing files. The actual file writing occurs in
@@ -43,6 +45,14 @@ public class FileTargetAdapter extends DefaultTargetAdapter {
}
}
public void setFileNameGenerator(FileNameGenerator fileNameGenerator) {
Assert.notNull(fileNameGenerator, "'fileNameGenerator' must not be null");
MessageMapper<?,?> mapper = this.getMessageMapper();
if (mapper instanceof AbstractFileMapper<?>) {
((AbstractFileMapper<?>) mapper).setFileNameGenerator(fileNameGenerator);
}
}
private static class FileTarget implements Target<File> {