From 4b9d65f021119d419b35008b013f2cef5093c508 Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Thu, 29 May 2014 08:38:55 +0300 Subject: [PATCH] Increase `FileProcessingTest` timeouts --- .../samples/fileprocessing/FileProcessingTest.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/intermediate/file-processing/src/test/java/org/springframework/integration/samples/fileprocessing/FileProcessingTest.java b/intermediate/file-processing/src/test/java/org/springframework/integration/samples/fileprocessing/FileProcessingTest.java index 462e22ae..2fe37616 100644 --- a/intermediate/file-processing/src/test/java/org/springframework/integration/samples/fileprocessing/FileProcessingTest.java +++ b/intermediate/file-processing/src/test/java/org/springframework/integration/samples/fileprocessing/FileProcessingTest.java @@ -1,5 +1,5 @@ /** - * + * */ package org.springframework.integration.samples.fileprocessing; @@ -21,7 +21,7 @@ import org.springframework.messaging.PollableChannel; public class FileProcessingTest { private int fileCount = 5; private Logger logger = Logger.getLogger(FileProcessingTest.class); - + @Before public void createDirectory(){ File directory = new File("input"); @@ -32,7 +32,7 @@ public class FileProcessingTest { } @Test - public void testSequentialFileProcessing() throws Exception { + public void testSequentialFileProcessing() throws Exception { logger.info("\n\n#### Starting Sequential processing test ####"); logger.info("Populating directory with files"); for (int i = 0; i < fileCount; i++) { @@ -42,12 +42,12 @@ public class FileProcessingTest { out.close(); } logger.info("Populated directory with files"); - Thread.sleep(2000); + Thread.sleep(5000); logger.info("Starting Spring Integration Sequential File processing"); ApplicationContext ac = new ClassPathXmlApplicationContext("META-INF/spring/integration/sequentialFileProcessing-config.xml"); PollableChannel filesOutChannel = ac.getBean("filesOutChannel", PollableChannel.class); for (int i = 0; i < fileCount; i++) { - logger.info("Finished processing " + filesOutChannel.receive(10000).getPayload()); + logger.info("Finished processing " + filesOutChannel.receive(20000).getPayload()); } } @Test