@@ -419,9 +419,9 @@ <R, S> boolean receiveAndReply(String queueName, ReceiveAndReplyCallback<R, S> c
419
419
* and attempt to receive a response. Implementations will normally set the reply-to
420
420
* header to an exclusive queue and wait up for some time limited by a timeout.
421
421
*
422
- * @param message a message to send
423
- * @return the response if there is one
424
- * @throws AmqpException if there is a problem
422
+ * @param message a message to send.
423
+ * @return the response; or null if the reply times out.
424
+ * @throws AmqpException if there is a problem.
425
425
*/
426
426
@ Nullable
427
427
Message sendAndReceive (Message message ) throws AmqpException ;
@@ -431,10 +431,10 @@ <R, S> boolean receiveAndReply(String queueName, ReceiveAndReplyCallback<R, S> c
431
431
* and attempt to receive a response. Implementations will normally set the reply-to
432
432
* header to an exclusive queue and wait up for some time limited by a timeout.
433
433
*
434
- * @param routingKey the routing key
435
- * @param message a message to send
436
- * @return the response if there is one
437
- * @throws AmqpException if there is a problem
434
+ * @param routingKey the routing key.
435
+ * @param message a message to send.
436
+ * @return the response; or null if the reply times out.
437
+ * @throws AmqpException if there is a problem.
438
438
*/
439
439
@ Nullable
440
440
Message sendAndReceive (String routingKey , Message message ) throws AmqpException ;
@@ -445,11 +445,11 @@ <R, S> boolean receiveAndReply(String queueName, ReceiveAndReplyCallback<R, S> c
445
445
* reply-to header to an exclusive queue and wait up for some time limited by a
446
446
* timeout.
447
447
*
448
- * @param exchange the name of the exchange
449
- * @param routingKey the routing key
450
- * @param message a message to send
451
- * @return the response if there is one
452
- * @throws AmqpException if there is a problem
448
+ * @param exchange the name of the exchange.
449
+ * @param routingKey the routing key.
450
+ * @param message a message to send.
451
+ * @return the response; or null if the reply times out.
452
+ * @throws AmqpException if there is a problem.
453
453
*/
454
454
@ Nullable
455
455
Message sendAndReceive (String exchange , String routingKey , Message message ) throws AmqpException ;
@@ -462,9 +462,9 @@ <R, S> boolean receiveAndReply(String queueName, ReceiveAndReplyCallback<R, S> c
462
462
* converting that to a Java object. Implementations will normally set the reply-to
463
463
* header to an exclusive queue and wait up for some time limited by a timeout.
464
464
*
465
- * @param message a message to send
466
- * @return the response if there is one
467
- * @throws AmqpException if there is a problem
465
+ * @param message a message to send.
466
+ * @return the response; or null if the reply times out.
467
+ * @throws AmqpException if there is a problem.
468
468
*/
469
469
@ Nullable
470
470
Object convertSendAndReceive (Object message ) throws AmqpException ;
@@ -475,10 +475,10 @@ <R, S> boolean receiveAndReply(String queueName, ReceiveAndReplyCallback<R, S> c
475
475
* converting that to a Java object. Implementations will normally set the reply-to
476
476
* header to an exclusive queue and wait up for some time limited by a timeout.
477
477
*
478
- * @param routingKey the routing key
479
- * @param message a message to send
480
- * @return the response if there is one
481
- * @throws AmqpException if there is a problem
478
+ * @param routingKey the routing key.
479
+ * @param message a message to send.
480
+ * @return the response; or null if the reply times out.
481
+ * @throws AmqpException if there is a problem.
482
482
*/
483
483
@ Nullable
484
484
Object convertSendAndReceive (String routingKey , Object message ) throws AmqpException ;
@@ -489,11 +489,11 @@ <R, S> boolean receiveAndReply(String queueName, ReceiveAndReplyCallback<R, S> c
489
489
* converting that to a Java object. Implementations will normally set the reply-to
490
490
* header to an exclusive queue and wait up for some time limited by a timeout.
491
491
*
492
- * @param exchange the name of the exchange
493
- * @param routingKey the routing key
494
- * @param message a message to send
495
- * @return the response if there is one
496
- * @throws AmqpException if there is a problem
492
+ * @param exchange the name of the exchange.
493
+ * @param routingKey the routing key.
494
+ * @param message a message to send.
495
+ * @return the response; or null if the reply times out.
496
+ * @throws AmqpException if there is a problem.
497
497
*/
498
498
@ Nullable
499
499
Object convertSendAndReceive (String exchange , String routingKey , Object message ) throws AmqpException ;
@@ -504,10 +504,10 @@ <R, S> boolean receiveAndReply(String queueName, ReceiveAndReplyCallback<R, S> c
504
504
* converting that to a Java object. Implementations will normally set the reply-to
505
505
* header to an exclusive queue and wait up for some time limited by a timeout.
506
506
*
507
- * @param message a message to send
508
- * @param messagePostProcessor a processor to apply to the message before it is sent
509
- * @return the response if there is one
510
- * @throws AmqpException if there is a problem
507
+ * @param message a message to send.
508
+ * @param messagePostProcessor a processor to apply to the message before it is sent.
509
+ * @return the response; or null if the reply times out.
510
+ * @throws AmqpException if there is a problem.
511
511
*/
512
512
@ Nullable
513
513
Object convertSendAndReceive (Object message , MessagePostProcessor messagePostProcessor ) throws AmqpException ;
@@ -518,11 +518,11 @@ <R, S> boolean receiveAndReply(String queueName, ReceiveAndReplyCallback<R, S> c
518
518
* converting that to a Java object. Implementations will normally set the reply-to
519
519
* header to an exclusive queue and wait up for some time limited by a timeout.
520
520
*
521
- * @param routingKey the routing key
522
- * @param message a message to send
523
- * @param messagePostProcessor a processor to apply to the message before it is sent
524
- * @return the response if there is one
525
- * @throws AmqpException if there is a problem
521
+ * @param routingKey the routing key.
522
+ * @param message a message to send.
523
+ * @param messagePostProcessor a processor to apply to the message before it is sent.
524
+ * @return the response; or null if the reply times out.
525
+ * @throws AmqpException if there is a problem.
526
526
*/
527
527
@ Nullable
528
528
Object convertSendAndReceive (String routingKey , Object message , MessagePostProcessor messagePostProcessor )
@@ -534,12 +534,12 @@ Object convertSendAndReceive(String routingKey, Object message, MessagePostProce
534
534
* converting that to a Java object. Implementations will normally set the reply-to
535
535
* header to an exclusive queue and wait up for some time limited by a timeout.
536
536
*
537
- * @param exchange the name of the exchange
538
- * @param routingKey the routing key
539
- * @param message a message to send
540
- * @param messagePostProcessor a processor to apply to the message before it is sent
541
- * @return the response if there is one
542
- * @throws AmqpException if there is a problem
537
+ * @param exchange the name of the exchange.
538
+ * @param routingKey the routing key.
539
+ * @param message a message to send.
540
+ * @param messagePostProcessor a processor to apply to the message before it is sent.
541
+ * @return the response; or null if the reply times out.
542
+ * @throws AmqpException if there is a problem.
543
543
*/
544
544
@ Nullable
545
545
Object convertSendAndReceive (String exchange , String routingKey , Object message ,
@@ -555,7 +555,7 @@ Object convertSendAndReceive(String exchange, String routingKey, Object message,
555
555
* @param message a message to send.
556
556
* @param responseType the type to convert the reply to.
557
557
* @param <T> the type.
558
- * @return the response if there is one .
558
+ * @return the response; or null if the reply times out .
559
559
* @throws AmqpException if there is a problem.
560
560
* @since 2.0
561
561
*/
@@ -569,12 +569,12 @@ <T> T convertSendAndReceiveAsType(Object message, ParameterizedTypeReference<T>
569
569
* converting that to a Java object. Implementations will normally set the reply-to
570
570
* header to an exclusive queue and wait up for some time limited by a timeout.
571
571
* Requires a {@link org.springframework.amqp.support.converter.SmartMessageConverter}.
572
- * @param routingKey the routing key
573
- * @param message a message to send
572
+ * @param routingKey the routing key.
573
+ * @param message a message to send.
574
574
* @param responseType the type to convert the reply to.
575
575
* @param <T> the type.
576
- * @return the response if there is one
577
- * @throws AmqpException if there is a problem
576
+ * @return the response; or null if the reply times out.
577
+ * @throws AmqpException if there is a problem.
578
578
* @since 2.0
579
579
*/
580
580
@ Nullable
@@ -587,13 +587,13 @@ <T> T convertSendAndReceiveAsType(String routingKey, Object message,
587
587
* converting that to a Java object. Implementations will normally set the reply-to
588
588
* header to an exclusive queue and wait up for some time limited by a timeout.
589
589
* Requires a {@link org.springframework.amqp.support.converter.SmartMessageConverter}.
590
- * @param exchange the name of the exchange
591
- * @param routingKey the routing key
592
- * @param message a message to send
590
+ * @param exchange the name of the exchange.
591
+ * @param routingKey the routing key.
592
+ * @param message a message to send.
593
593
* @param responseType the type to convert the reply to.
594
594
* @param <T> the type.
595
- * @return the response if there is one
596
- * @throws AmqpException if there is a problem
595
+ * @return the response; or null if the reply times out.
596
+ * @throws AmqpException if there is a problem.
597
597
* @since 2.0
598
598
*/
599
599
@ Nullable
@@ -606,12 +606,12 @@ <T> T convertSendAndReceiveAsType(String exchange, String routingKey, Object mes
606
606
* converting that to a Java object. Implementations will normally set the reply-to
607
607
* header to an exclusive queue and wait up for some time limited by a timeout.
608
608
* Requires a {@link org.springframework.amqp.support.converter.SmartMessageConverter}.
609
- * @param message a message to send
610
- * @param messagePostProcessor a processor to apply to the message before it is sent
609
+ * @param message a message to send.
610
+ * @param messagePostProcessor a processor to apply to the message before it is sent.
611
611
* @param responseType the type to convert the reply to.
612
612
* @param <T> the type.
613
- * @return the response if there is one
614
- * @throws AmqpException if there is a problem
613
+ * @return the response; or null if the reply times out.
614
+ * @throws AmqpException if there is a problem.
615
615
* @since 2.0
616
616
*/
617
617
@ Nullable
@@ -624,13 +624,13 @@ <T> T convertSendAndReceiveAsType(Object message, MessagePostProcessor messagePo
624
624
* converting that to a Java object. Implementations will normally set the reply-to
625
625
* header to an exclusive queue and wait up for some time limited by a timeout.
626
626
* Requires a {@link org.springframework.amqp.support.converter.SmartMessageConverter}.
627
- * @param routingKey the routing key
628
- * @param message a message to send
629
- * @param messagePostProcessor a processor to apply to the message before it is sent
627
+ * @param routingKey the routing key.
628
+ * @param message a message to send.
629
+ * @param messagePostProcessor a processor to apply to the message before it is sent.
630
630
* @param responseType the type to convert the reply to.
631
631
* @param <T> the type.
632
- * @return the response if there is one
633
- * @throws AmqpException if there is a problem
632
+ * @return the response; or null if the reply times out.
633
+ * @throws AmqpException if there is a problem.
634
634
* @since 2.0
635
635
*/
636
636
@ Nullable
@@ -644,14 +644,14 @@ <T> T convertSendAndReceiveAsType(String routingKey, Object message,
644
644
* converting that to a Java object. Implementations will normally set the reply-to
645
645
* header to an exclusive queue and wait up for some time limited by a timeout.
646
646
* Requires a {@link org.springframework.amqp.support.converter.SmartMessageConverter}.
647
- * @param exchange the name of the exchange
648
- * @param routingKey the routing key
649
- * @param message a message to send
650
- * @param messagePostProcessor a processor to apply to the message before it is sent
647
+ * @param exchange the name of the exchange.
648
+ * @param routingKey the routing key.
649
+ * @param message a message to send.
650
+ * @param messagePostProcessor a processor to apply to the message before it is sent.
651
651
* @param responseType the type to convert the reply to.
652
652
* @param <T> the type.
653
- * @return the response if there is one
654
- * @throws AmqpException if there is a problem
653
+ * @return the response; or null if the reply times out.
654
+ * @throws AmqpException if there is a problem.
655
655
* @since 2.0
656
656
*/
657
657
@ Nullable
0 commit comments