From 62b60cfe8546de057443e750901b86dfc96090dd Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Sat, 12 Aug 2023 12:58:04 -0400 Subject: [PATCH] Fix `AggregatorTests` for deprecations --- .../integration/aggregator/AggregatorTests.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/spring-integration-core/src/test/java/org/springframework/integration/aggregator/AggregatorTests.java b/spring-integration-core/src/test/java/org/springframework/integration/aggregator/AggregatorTests.java index c2df32b457..a6c3870c0a 100644 --- a/spring-integration-core/src/test/java/org/springframework/integration/aggregator/AggregatorTests.java +++ b/spring-integration-core/src/test/java/org/springframework/integration/aggregator/AggregatorTests.java @@ -115,14 +115,14 @@ public class AggregatorTests { if (i % 10000 == 0) { stopwatch.stop(); logger.warn("Sent " + i + " in " + stopwatch.getTotalTimeSeconds() + - " (10k in " + stopwatch.getLastTaskTimeMillis() + "ms)"); + " (10k in " + stopwatch.lastTaskInfo().getTimeMillis() + "ms)"); stopwatch.start(); } handler.handleMessage(message); } stopwatch.stop(); logger.warn("Sent " + 120000 + " in " + stopwatch.getTotalTimeSeconds() + - " (10k in " + stopwatch.getLastTaskTimeMillis() + "ms)"); + " (10k in " + stopwatch.lastTaskInfo().getTimeMillis() + "ms)"); Collection result = resultFuture.get(10, TimeUnit.SECONDS); assertThat(result).isNotNull(); @@ -130,7 +130,7 @@ public class AggregatorTests { } @Test - @Ignore("Time sensitive") + @Disabled("Time sensitive") public void testAggPerfDefaultPartial() throws InterruptedException, ExecutionException, TimeoutException { AggregatingMessageHandler handler = new AggregatingMessageHandler(new DefaultAggregatingMessageGroupProcessor()); handler.setCorrelationStrategy(message -> "foo"); @@ -161,7 +161,7 @@ public class AggregatorTests { if (i % 10000 == 0) { stopwatch.stop(); logger.warn("Sent " + i + " in " + stopwatch.getTotalTimeSeconds() + - " (10k in " + stopwatch.getLastTaskTimeMillis() + "ms)"); + " (10k in " + stopwatch.lastTaskInfo().getTimeMillis() + "ms)"); stopwatch.start(); } handler.handleMessage(MessageBuilder.withPayload("foo")