|
37 | 37 | import org.junit.rules.TemporaryFolder;
|
38 | 38 |
|
39 | 39 | import org.springframework.beans.factory.BeanFactory;
|
40 |
| -import org.springframework.integration.file.filters.AcceptOnceFileListFilter; |
| 40 | +import org.springframework.integration.file.filters.FileSystemPersistentAcceptOnceFileListFilter; |
| 41 | +import org.springframework.integration.metadata.SimpleMetadataStore; |
41 | 42 |
|
42 | 43 | /**
|
43 | 44 | * @author Gary Russell
|
@@ -78,15 +79,18 @@ public void testInitialAndAddMoreThanRemove() throws Exception {
|
78 | 79 |
|
79 | 80 | final CountDownLatch removeFileLatch = new CountDownLatch(1);
|
80 | 81 |
|
81 |
| - fileReadingMessageSource.setFilter(new AcceptOnceFileListFilter<File>() { |
| 82 | + FileSystemPersistentAcceptOnceFileListFilter filter = |
| 83 | + new FileSystemPersistentAcceptOnceFileListFilter(new SimpleMetadataStore(), "test") { |
82 | 84 |
|
83 |
| - @Override |
84 |
| - public boolean remove(File fileToRemove) { |
85 |
| - removeFileLatch.countDown(); |
86 |
| - return super.remove(fileToRemove); |
87 |
| - } |
| 85 | + @Override |
| 86 | + public boolean remove(File fileToRemove) { |
| 87 | + removeFileLatch.countDown(); |
| 88 | + return super.remove(fileToRemove); |
| 89 | + } |
| 90 | + |
| 91 | + }; |
88 | 92 |
|
89 |
| - }); |
| 93 | + fileReadingMessageSource.setFilter(filter); |
90 | 94 | fileReadingMessageSource.afterPropertiesSet();
|
91 | 95 | fileReadingMessageSource.start();
|
92 | 96 | DirectoryScanner scanner = fileReadingMessageSource.getScanner();
|
@@ -153,6 +157,15 @@ public boolean remove(File fileToRemove) {
|
153 | 157 |
|
154 | 158 | assertTrue(accum.contains(baz2));
|
155 | 159 |
|
| 160 | + File baz2Copy = new File(baz2.getAbsolutePath()); |
| 161 | + |
| 162 | + baz2Copy.setLastModified(baz2.lastModified() + 100000); |
| 163 | + |
| 164 | + files = scanner.listFiles(folder.getRoot()); |
| 165 | + |
| 166 | + assertEquals(1, files.size()); |
| 167 | + assertTrue(files.contains(baz2)); |
| 168 | + |
156 | 169 | baz2.delete();
|
157 | 170 |
|
158 | 171 | scanner.listFiles(folder.getRoot());
|
|
0 commit comments