@@ -341,15 +341,15 @@ public void testAnnotatedServiceActivator() throws Exception {
341
341
342
342
this .input .send (MessageBuilder .withPayload ("Foo" ).build ());
343
343
344
- Message <?> interceptedMessage = this .wireTapChannel .receive (10000 );
344
+ Message <?> interceptedMessage = this .wireTapChannel .receive (10_000 );
345
345
assertThat (interceptedMessage ).isNotNull ();
346
346
assertThat (interceptedMessage .getPayload ()).isEqualTo ("Foo" );
347
347
348
- Message <?> receive = this .output .receive (10000 );
348
+ Message <?> receive = this .output .receive (10_000 );
349
349
assertThat (receive ).isNotNull ();
350
350
assertThat (receive .getPayload ()).isEqualTo ("FOO" );
351
351
352
- receive = this .wireTapFromOutput .receive (10000 );
352
+ receive = this .wireTapFromOutput .receive (10_000 );
353
353
assertThat (receive ).isNotNull ();
354
354
assertThat (receive .getPayload ()).isEqualTo ("FOO" );
355
355
@@ -360,7 +360,7 @@ public void testAnnotatedServiceActivator() throws Exception {
360
360
assertThat (messageHistoryString ).contains ("annotationTestService.handle.serviceActivator.handler" );
361
361
assertThat (messageHistoryString ).doesNotContain ("output" );
362
362
363
- receive = this .publishedChannel .receive (10000 );
363
+ receive = this .publishedChannel .receive (10_000 );
364
364
365
365
assertThat (receive ).isNotNull ();
366
366
assertThat (receive .getPayload ()).isEqualTo ("foo" );
@@ -389,20 +389,20 @@ public void testAnnotatedServiceActivator() throws Exception {
389
389
countSA .start ();
390
390
391
391
for (int i = 0 ; i < 10 ; i ++) {
392
- Message <?> message = this .counterChannel .receive (1000 );
392
+ Message <?> message = this .counterChannel .receive (10_000 );
393
393
assertThat (message ).isNotNull ();
394
394
assertThat (message .getPayload ()).isEqualTo (i + 1 );
395
395
}
396
396
397
- Message <?> message = this .fooChannel .receive (1000 );
397
+ Message <?> message = this .fooChannel .receive (10_000 );
398
398
assertThat (message ).isNotNull ();
399
399
assertThat (message .getPayload ()).isEqualTo ("foo" );
400
- message = this .fooChannel .receive (1000 );
400
+ message = this .fooChannel .receive (10_000 );
401
401
assertThat (message ).isNotNull ();
402
402
assertThat (message .getPayload ()).isEqualTo ("foo" );
403
403
assertThat (this .fooChannel .receive (10 )).isNull ();
404
404
405
- message = this .messageChannel .receive (1000 );
405
+ message = this .messageChannel .receive (10_000 );
406
406
assertThat (message ).isNotNull ();
407
407
assertThat (message .getPayload ()).isEqualTo ("bar" );
408
408
assertThat (message .getHeaders ().containsKey ("foo" )).isTrue ();
0 commit comments