From 1ca1b2c1654fff7a5d2374e74479d219fad16074 Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Tue, 28 Aug 2018 16:23:31 -0400 Subject: [PATCH] Fix imports in DelayHandlerTests https://build.spring.io/browse/INT-SI50X-135/ * Rename to `RouterConcurrencyTests` for consistency --- .../integration/handler/DelayHandlerTests.java | 2 +- ...terConcurrencyTest.java => RouterConcurrencyTests.java} | 7 ++++--- 2 files changed, 5 insertions(+), 4 deletions(-) rename spring-integration-core/src/test/java/org/springframework/integration/router/{RouterConcurrencyTest.java => RouterConcurrencyTests.java} (97%) diff --git a/spring-integration-core/src/test/java/org/springframework/integration/handler/DelayHandlerTests.java b/spring-integration-core/src/test/java/org/springframework/integration/handler/DelayHandlerTests.java index cf42886e68..0d8bae4e1a 100644 --- a/spring-integration-core/src/test/java/org/springframework/integration/handler/DelayHandlerTests.java +++ b/spring-integration-core/src/test/java/org/springframework/integration/handler/DelayHandlerTests.java @@ -45,7 +45,6 @@ import org.springframework.context.event.ContextRefreshedEvent; import org.springframework.context.support.StaticApplicationContext; import org.springframework.expression.Expression; import org.springframework.expression.spel.standard.SpelExpressionParser; -import org.springframework.integration.StaticMessageHeaderAccessor; import org.springframework.integration.channel.DirectChannel; import org.springframework.integration.channel.MessagePublishingErrorHandler; import org.springframework.integration.channel.QueueChannel; @@ -54,6 +53,7 @@ import org.springframework.integration.store.MessageGroup; import org.springframework.integration.store.MessageGroupStore; import org.springframework.integration.store.SimpleMessageStore; import org.springframework.integration.support.MessageBuilder; +import org.springframework.integration.support.StaticMessageHeaderAccessor; import org.springframework.integration.test.util.TestUtils; import org.springframework.integration.test.util.TestUtils.TestApplicationContext; import org.springframework.messaging.Message; diff --git a/spring-integration-core/src/test/java/org/springframework/integration/router/RouterConcurrencyTest.java b/spring-integration-core/src/test/java/org/springframework/integration/router/RouterConcurrencyTests.java similarity index 97% rename from spring-integration-core/src/test/java/org/springframework/integration/router/RouterConcurrencyTest.java rename to spring-integration-core/src/test/java/org/springframework/integration/router/RouterConcurrencyTests.java index abe999610c..7a03d93411 100644 --- a/spring-integration-core/src/test/java/org/springframework/integration/router/RouterConcurrencyTest.java +++ b/spring-integration-core/src/test/java/org/springframework/integration/router/RouterConcurrencyTests.java @@ -42,16 +42,18 @@ import org.springframework.messaging.MessageChannel; /** * @author Gary Russell + * * @since 3.0 * */ -public class RouterConcurrencyTest { +public class RouterConcurrencyTests { @Test public void test() throws Exception { final AtomicInteger count = new AtomicInteger(); final Semaphore semaphore = new Semaphore(1); final AbstractMessageRouter router = new AbstractMessageRouter() { + @Override protected Collection determineTargetChannels(Message message) { return null; @@ -85,8 +87,7 @@ public class RouterConcurrencyTest { router.setBeanFactory(beanFactory); ExecutorService exec = Executors.newFixedThreadPool(2); - final List returns = Collections.synchronizedList( - new ArrayList()); + final List returns = Collections.synchronizedList(new ArrayList<>()); Runnable runnable = () -> { ConversionService requiredConversionService = router.getRequiredConversionService(); returns.add(requiredConversionService);