diff --git a/org.springframework.integration.file/src/test/java/org/springframework/integration/file/PollableFileSourceIntegrationTests-context.xml b/org.springframework.integration.file/src/test/java/org/springframework/integration/file/FileReadingMessageSourceIntegrationTests-context.xml
similarity index 92%
rename from org.springframework.integration.file/src/test/java/org/springframework/integration/file/PollableFileSourceIntegrationTests-context.xml
rename to org.springframework.integration.file/src/test/java/org/springframework/integration/file/FileReadingMessageSourceIntegrationTests-context.xml
index 1f39e526bc..d9ac05318a 100644
--- a/org.springframework.integration.file/src/test/java/org/springframework/integration/file/PollableFileSourceIntegrationTests-context.xml
+++ b/org.springframework.integration.file/src/test/java/org/springframework/integration/file/FileReadingMessageSourceIntegrationTests-context.xml
@@ -7,7 +7,7 @@
diff --git a/org.springframework.integration.file/src/test/java/org/springframework/integration/file/PollableFileSourceIntegrationTests.java b/org.springframework.integration.file/src/test/java/org/springframework/integration/file/FileReadingMessageSourceIntegrationTests.java
similarity index 97%
rename from org.springframework.integration.file/src/test/java/org/springframework/integration/file/PollableFileSourceIntegrationTests.java
rename to org.springframework.integration.file/src/test/java/org/springframework/integration/file/FileReadingMessageSourceIntegrationTests.java
index 56e16f37d2..fc69d276c2 100644
--- a/org.springframework.integration.file/src/test/java/org/springframework/integration/file/PollableFileSourceIntegrationTests.java
+++ b/org.springframework.integration.file/src/test/java/org/springframework/integration/file/FileReadingMessageSourceIntegrationTests.java
@@ -43,7 +43,7 @@ import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
*/
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration
-public class PollableFileSourceIntegrationTests {
+public class FileReadingMessageSourceIntegrationTests {
@Autowired
FileReadingMessageSource pollableFileSource;
@@ -54,7 +54,7 @@ public class PollableFileSourceIntegrationTests {
@BeforeClass
public static void setupInputDir() {
inputDir = new File(System.getProperty("java.io.tmpdir") + "/"
- + PollableFileSourceIntegrationTests.class.getSimpleName());
+ + FileReadingMessageSourceIntegrationTests.class.getSimpleName());
inputDir.mkdir();
}
@@ -111,8 +111,8 @@ public class PollableFileSourceIntegrationTests {
assertNotSame(received2 + " == " + received3, received2, received3);
}
- @Test(timeout = 3000)
- @Repeat(15)
+ @Test(timeout = 6000)
+ @Repeat(10)
public void concurrentProcessing() throws Exception {
CountDownLatch go = new CountDownLatch(1);
Runnable succesfulConsumer = new Runnable() {
diff --git a/org.springframework.integration.file/src/test/java/org/springframework/integration/file/PollableFileSourceTests.java b/org.springframework.integration.file/src/test/java/org/springframework/integration/file/FileReadingMessageSourceTests.java
similarity index 81%
rename from org.springframework.integration.file/src/test/java/org/springframework/integration/file/PollableFileSourceTests.java
rename to org.springframework.integration.file/src/test/java/org/springframework/integration/file/FileReadingMessageSourceTests.java
index 2c3648fa26..31d22aac76 100644
--- a/org.springframework.integration.file/src/test/java/org/springframework/integration/file/PollableFileSourceTests.java
+++ b/org.springframework.integration.file/src/test/java/org/springframework/integration/file/FileReadingMessageSourceTests.java
@@ -31,9 +31,9 @@ import org.springframework.integration.core.Message;
* @author Iwein Fuld
*/
@SuppressWarnings("unchecked")
-public class PollableFileSourceTests {
+public class FileReadingMessageSourceTests {
- private FileReadingMessageSource pollableFileSource;
+ private FileReadingMessageSource source;
private File inputDirectoryMock = createMock(File.class);
@@ -53,8 +53,8 @@ public class PollableFileSourceTests {
@Before
public void initialize() throws Exception {
prepResource();
- this.pollableFileSource = new FileReadingMessageSource();
- pollableFileSource.setInputDirectory(inputDirectoryResourceMock);
+ this.source = new FileReadingMessageSource();
+ source.setInputDirectory(inputDirectoryResourceMock);
reset(allMocks);
}
@@ -62,7 +62,7 @@ public class PollableFileSourceTests {
public void straightProcess() throws Exception {
expect(inputDirectoryMock.listFiles()).andReturn(new File[] { fileMock });
replay(allMocks);
- pollableFileSource.onSend(pollableFileSource.receive());
+ source.onSend(source.receive());
verify(allMocks);
}
@@ -71,10 +71,10 @@ public class PollableFileSourceTests {
expect(inputDirectoryMock.listFiles()).andReturn(new File[] { fileMock });
expect(inputDirectoryMock.listFiles()).andReturn(new File[] {});
replay(allMocks);
- Message received = pollableFileSource.receive();
+ Message received = source.receive();
assertNotNull(received);
- pollableFileSource.onFailure(received, new RuntimeException("failed"));
- assertEquals(received.getPayload(), pollableFileSource.receive().getPayload());
+ source.onFailure(received, new RuntimeException("failed"));
+ assertEquals(received.getPayload(), source.receive().getPayload());
verify(allMocks);
}
@@ -83,10 +83,10 @@ public class PollableFileSourceTests {
expect(inputDirectoryMock.listFiles()).andReturn(new File[] { fileMock });
expect(inputDirectoryMock.listFiles()).andReturn(new File[] {});
replay(allMocks);
- Message received = pollableFileSource.receive();
+ Message received = source.receive();
assertNotNull(received);
assertEquals(fileMock, received.getPayload());
- assertNull(pollableFileSource.receive());
+ assertNull(source.receive());
verify(allMocks);
}
}