@@ -115,22 +115,22 @@ public void testAggPerf() throws InterruptedException, ExecutionException, Timeo
115115 if (i % 10000 == 0 ) {
116116 stopwatch .stop ();
117117 logger .warn ("Sent " + i + " in " + stopwatch .getTotalTimeSeconds () +
118- " (10k in " + stopwatch .getLastTaskTimeMillis () + "ms)" );
118+ " (10k in " + stopwatch .lastTaskInfo (). getTimeMillis () + "ms)" );
119119 stopwatch .start ();
120120 }
121121 handler .handleMessage (message );
122122 }
123123 stopwatch .stop ();
124124 logger .warn ("Sent " + 120000 + " in " + stopwatch .getTotalTimeSeconds () +
125- " (10k in " + stopwatch .getLastTaskTimeMillis () + "ms)" );
125+ " (10k in " + stopwatch .lastTaskInfo (). getTimeMillis () + "ms)" );
126126
127127 Collection <?> result = resultFuture .get (10 , TimeUnit .SECONDS );
128128 assertThat (result ).isNotNull ();
129129 assertThat (result .size ()).isEqualTo (60000 );
130130 }
131131
132132 @ Test
133- @ Ignore ("Time sensitive" )
133+ @ Disabled ("Time sensitive" )
134134 public void testAggPerfDefaultPartial () throws InterruptedException , ExecutionException , TimeoutException {
135135 AggregatingMessageHandler handler = new AggregatingMessageHandler (new DefaultAggregatingMessageGroupProcessor ());
136136 handler .setCorrelationStrategy (message -> "foo" );
@@ -161,7 +161,7 @@ public void testAggPerfDefaultPartial() throws InterruptedException, ExecutionEx
161161 if (i % 10000 == 0 ) {
162162 stopwatch .stop ();
163163 logger .warn ("Sent " + i + " in " + stopwatch .getTotalTimeSeconds () +
164- " (10k in " + stopwatch .getLastTaskTimeMillis () + "ms)" );
164+ " (10k in " + stopwatch .lastTaskInfo (). getTimeMillis () + "ms)" );
165165 stopwatch .start ();
166166 }
167167 handler .handleMessage (MessageBuilder .withPayload ("foo" )
0 commit comments