@@ -115,22 +115,22 @@ public void testAggPerf() throws InterruptedException, ExecutionException, Timeo
115
115
if (i % 10000 == 0 ) {
116
116
stopwatch .stop ();
117
117
logger .warn ("Sent " + i + " in " + stopwatch .getTotalTimeSeconds () +
118
- " (10k in " + stopwatch .getLastTaskTimeMillis () + "ms)" );
118
+ " (10k in " + stopwatch .lastTaskInfo (). getTimeMillis () + "ms)" );
119
119
stopwatch .start ();
120
120
}
121
121
handler .handleMessage (message );
122
122
}
123
123
stopwatch .stop ();
124
124
logger .warn ("Sent " + 120000 + " in " + stopwatch .getTotalTimeSeconds () +
125
- " (10k in " + stopwatch .getLastTaskTimeMillis () + "ms)" );
125
+ " (10k in " + stopwatch .lastTaskInfo (). getTimeMillis () + "ms)" );
126
126
127
127
Collection <?> result = resultFuture .get (10 , TimeUnit .SECONDS );
128
128
assertThat (result ).isNotNull ();
129
129
assertThat (result .size ()).isEqualTo (60000 );
130
130
}
131
131
132
132
@ Test
133
- @ Ignore ("Time sensitive" )
133
+ @ Disabled ("Time sensitive" )
134
134
public void testAggPerfDefaultPartial () throws InterruptedException , ExecutionException , TimeoutException {
135
135
AggregatingMessageHandler handler = new AggregatingMessageHandler (new DefaultAggregatingMessageGroupProcessor ());
136
136
handler .setCorrelationStrategy (message -> "foo" );
@@ -161,7 +161,7 @@ public void testAggPerfDefaultPartial() throws InterruptedException, ExecutionEx
161
161
if (i % 10000 == 0 ) {
162
162
stopwatch .stop ();
163
163
logger .warn ("Sent " + i + " in " + stopwatch .getTotalTimeSeconds () +
164
- " (10k in " + stopwatch .getLastTaskTimeMillis () + "ms)" );
164
+ " (10k in " + stopwatch .lastTaskInfo (). getTimeMillis () + "ms)" );
165
165
stopwatch .start ();
166
166
}
167
167
handler .handleMessage (MessageBuilder .withPayload ("foo" )
0 commit comments