You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Fix description for `prefetch`; remove reference to transactions since
the direct container does not support transactionSize.
Also fix `transactionSize` to just reference acks; autoConfiguration
doesn't support enabling transactions.
Closesgh-14569
Copy file name to clipboardExpand all lines: spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/amqp/RabbitProperties.java
+4-5Lines changed: 4 additions & 5 deletions
Original file line number
Diff line number
Diff line change
@@ -577,8 +577,8 @@ public abstract static class AmqpContainer {
577
577
privateAcknowledgeModeacknowledgeMode;
578
578
579
579
/**
580
-
* Number of messages to be handled in a single request. It should be greater than
581
-
* or equal to the transaction size (if used).
580
+
* Maximum number of unacknowledged messages that can be outstanding at each
581
+
* consumer.
582
582
*/
583
583
privateIntegerprefetch;
584
584
@@ -659,9 +659,8 @@ public static class SimpleContainer extends AmqpContainer {
659
659
privateIntegermaxConcurrency;
660
660
661
661
/**
662
-
* Number of messages to be processed in a transaction. That is, the number of
663
-
* messages between acks. For best results, it should be less than or equal to the
664
-
* prefetch count.
662
+
* Number of messages to be processed between acks when the acknowledge mode is
663
+
* AUTO. If larger than prefetch, prefetch will be increased to this value.
Copy file name to clipboardExpand all lines: spring-boot-project/spring-boot-docs/src/main/asciidoc/appendix-application-properties.adoc
+2-2Lines changed: 2 additions & 2 deletions
Display the source diff
Display the rich diff
Original file line number
Diff line number
Diff line change
@@ -1082,7 +1082,7 @@ content into your application. Rather, pick only the properties that you need.
1082
1082
spring.rabbitmq.listener.direct.consumers-per-queue= # Number of consumers per queue.
1083
1083
spring.rabbitmq.listener.direct.default-requeue-rejected= # Whether rejected deliveries are re-queued by default.
1084
1084
spring.rabbitmq.listener.direct.idle-event-interval= # How often idle container events should be published.
1085
-
spring.rabbitmq.listener.direct.prefetch= # Number of messages to be handled in a single request. It should be greater than or equal to the transaction size (if used).
1085
+
spring.rabbitmq.listener.direct.prefetch= # Maximum number of unacknowledged messages that can be outstanding at each consumer.
1086
1086
spring.rabbitmq.listener.direct.retry.enabled=false # Whether publishing retries are enabled.
1087
1087
spring.rabbitmq.listener.direct.retry.initial-interval=1000ms # Duration between the first and second attempt to deliver a message.
1088
1088
spring.rabbitmq.listener.direct.retry.max-attempts=3 # Maximum number of attempts to deliver a message.
@@ -1102,7 +1102,7 @@ content into your application. Rather, pick only the properties that you need.
1102
1102
spring.rabbitmq.listener.simple.retry.max-interval=10000ms # Maximum duration between attempts.
1103
1103
spring.rabbitmq.listener.simple.retry.multiplier=1 # Multiplier to apply to the previous retry interval.
1104
1104
spring.rabbitmq.listener.simple.retry.stateless=true # Whether retries are stateless or stateful.
1105
-
spring.rabbitmq.listener.simple.transaction-size= # Number of messages to be processed in a transaction. That is, the number of messages between acks. For best results, it should be less than or equal to the prefetch count.
1105
+
spring.rabbitmq.listener.simple.transaction-size= # Number of messages to be processed between acks when the acknowledge mode is AUTO. If larger than prefetch, prefetch will be increased to this value.
0 commit comments