diff --git a/org.springframework.integration/src/test/java/org/springframework/integration/executor/ErrorHandlingExecutorBeanPostProcessorTests.java b/org.springframework.integration/src/test/java/org/springframework/integration/executor/ErrorHandlingExecutorBeanPostProcessorTests.java index 1bd4690682..e5514c07ec 100644 --- a/org.springframework.integration/src/test/java/org/springframework/integration/executor/ErrorHandlingExecutorBeanPostProcessorTests.java +++ b/org.springframework.integration/src/test/java/org/springframework/integration/executor/ErrorHandlingExecutorBeanPostProcessorTests.java @@ -49,7 +49,7 @@ public class ErrorHandlingExecutorBeanPostProcessorTests { ErrorThrowingRunnable runnable = new ErrorThrowingRunnable(); taskExecutor.execute(runnable); assertTrue("Runnable faield to run",runnable.latch.await(5, TimeUnit.SECONDS)); - Thread.sleep(100); + Thread.sleep(500); assertEquals("Incorrect count of exceptions", 1, errorHandler.throwables.size()); } @@ -59,7 +59,7 @@ public class ErrorHandlingExecutorBeanPostProcessorTests { ErrorThrowingRunnable runnable = new ErrorThrowingRunnable(); taskExecutor.execute(runnable); assertTrue("Runnable faield to run",runnable.latch.await(5, TimeUnit.SECONDS)); - Thread.sleep(100); + Thread.sleep(500); assertEquals("Incorrect count of exceptions", 0, errorHandler.throwables.size()); } diff --git a/org.springframework.integration/src/test/java/org/springframework/integration/executor/RunnableProxyingMethodInterceptorTests.java b/org.springframework.integration/src/test/java/org/springframework/integration/executor/RunnableProxyingMethodInterceptorTests.java index ead843bf4a..2d103227f5 100644 --- a/org.springframework.integration/src/test/java/org/springframework/integration/executor/RunnableProxyingMethodInterceptorTests.java +++ b/org.springframework.integration/src/test/java/org/springframework/integration/executor/RunnableProxyingMethodInterceptorTests.java @@ -56,6 +56,7 @@ public class RunnableProxyingMethodInterceptorTests { proxiedExecutor.execute(runnable); assertTrue("Runnable did not run", runnable.countDown.await(5, TimeUnit.SECONDS)); + Thread.sleep(500); assertEquals("Wrong count of exceptions in ErrorHandler", 1, errorHandler.throwables.size()); }