From d5c39bc5d177746704bc3cfaed2b2d94d730ad9c Mon Sep 17 00:00:00 2001 From: buildmaster Date: Fri, 22 Nov 2019 14:22:22 +0000 Subject: [PATCH] Update SNAPSHOT to 3.0.0.RELEASE --- README.adoc | 73 ++++++++++++++++++- docs/pom.xml | 2 +- pom.xml | 6 +- spring-cloud-starter-stream-rabbit/pom.xml | 2 +- .../pom.xml | 2 +- .../pom.xml | 2 +- spring-cloud-stream-binder-rabbit/pom.xml | 2 +- 7 files changed, 77 insertions(+), 12 deletions(-) diff --git a/README.adoc b/README.adoc index ed83ff48a..c2b490119 100644 --- a/README.adoc +++ b/README.adoc @@ -87,7 +87,7 @@ You can exclude the class by using the `@SpringBootApplication` annotation. Starting with version 2.0, the `RabbitMessageChannelBinder` sets the `RabbitTemplate.userPublisherConnection` property to `true` so that the non-transactional producers avoid deadlocks on consumers, which can happen if cached connections are blocked because of a https://www.rabbitmq.com/memory.html[memory alarm] on the broker. -NOTE: Currently, a `multiplex` consumer (a single consumer listening to multiple queues) is only supported for message-driven consumers; polled consumers can only retrieve messages from a single queue. +NOTE: Currently, a `multiplex` consumer (a single consumer listening to multiple queues) is only supported for message-driven conssumers; polled consumers can only retrieve messages from a single queue. == Configuration Options @@ -159,9 +159,14 @@ Whether to automatically declare the DLQ and bind it to the binder DLX. Default: `false`. bindingRoutingKey:: The routing key with which to bind the queue to the exchange (if `bindQueue` is `true`). -For partitioned destinations, `-` is appended. +Can be multiple keys - see `bindingRoutingKeyDelimiter`. +For partitioned destinations, `-` is appended to each key. + Default: `#`. +bindingRoutingKeyDelimiter:: +When this is not null, 'bindingRoutingKey' is considered to be a list of keys delimited by this value; often a comma is used. ++ +Default: `null`. bindQueue:: Whether to declare the queue and bind it to the destination exchange. Set it to `false` if you have set up your own infrastructure and have previously created and bound the queue. @@ -251,6 +256,18 @@ dlqOverflowBehavior:: Action to take when `dlqMaxLength` or `dlqMaxLengthBytes` is exceeded; currently `drop-head` or `reject-publish` but refer to the RabbitMQ documentation. + Default: `none` +dlqQuorum.deliveryLimit:: +When `quorum.enabled=true`, set a delivery limit after which the message is dropped or dead-lettered. ++ +Default: none - broker default will apply. +dlqQuorum.enabled:: +When true, create a quorum dead letter queue instead of a classic queue. ++ +Default: false +dlqQuorum.initialQuorumSize:: +When `quorum.enabled=true`, set the initial quorum size. ++ +Default: none - broker default will apply. dlqTtl:: Default time to live to apply to the dead letter queue when declared (in milliseconds). + @@ -357,6 +374,18 @@ Otherwise the queue name is `destination.group`. This is useful, for example, when using Spring Cloud Stream to consume from an existing RabbitMQ queue. + Default: false. +quorum.deliveryLimit:: +When `quorum.enabled=true`, set a delivery limit after which the message is dropped or dead-lettered. ++ +Default: none - broker default will apply. +quorum.enabled:: +When true, create a quorum queue instead of a classic queue. ++ +Default: false +quorum.initialQuorumSize:: +When `quorum.enabled=true`, set the initial quorum size. ++ +Default: none - broker default will apply. recoveryInterval:: The interval between connection recovery attempts, in milliseconds. + @@ -440,10 +469,16 @@ The batch timeout when batching is enabled. Default: `5000`. bindingRoutingKey:: The routing key with which to bind the queue to the exchange (if `bindQueue` is `true`). -Only applies to non-partitioned destinations. +Can be multiple keys - see `bindingRoutingKeyDelimiter`. +For partitioned destinations, `-n` is appended to each key. Only applies if `requiredGroups` are provided and then only to those groups. + Default: `#`. +bindingRoutingKeyDelimiter:: +When this is not null, 'bindingRoutingKey' is considered to be a list of keys delimited by this value; often a comma is used. +Only applies if `requiredGroups` are provided and then only to those groups. ++ +Default: `null`. bindQueue:: Whether to declare the queue and bind it to the destination exchange. Set it to `false` if you have set up your own infrastructure and have previously created and bound the queue. @@ -551,6 +586,21 @@ Maximum priority of messages in the dead letter queue (0-255) Applies only when `requiredGroups` are provided and then only to those groups. + Default: `none` +dlqQuorum.deliveryLimit:: +When `quorum.enabled=true`, set a delivery limit after which the message is dropped or dead-lettered. +Applies only when `requiredGroups` are provided and then only to those groups. ++ +Default: none - broker default will apply. +dlqQuorum.enabled:: +When true, create a quorum dead letter queue instead of a classic queue. +Applies only when `requiredGroups` are provided and then only to those groups. ++ +Default: false +dlqQuorum.initialQuorumSize:: +When `quorum.enabled=true`, set the initial quorum size. +Applies only when `requiredGroups` are provided and then only to those groups. ++ +Default: none - broker default will apply. dlqTtl:: Default time (in milliseconds) to live to apply to the dead letter queue when declared. Applies only when `requiredGroups` are provided and then only to those groups. @@ -616,6 +666,21 @@ This is useful, for example, when using Spring Cloud Stream to consume from an e Applies only when `requiredGroups` are provided and then only to those groups. + Default: false. +quorum.deliveryLimit:: +When `quorum.enabled=true`, set a delivery limit after which the message is dropped or dead-lettered. +Applies only when `requiredGroups` are provided and then only to those groups. ++ +Default: none - broker default will apply. +quorum.enabled:: +When true, create a quorum queue instead of a classic queue. +Applies only when `requiredGroups` are provided and then only to those groups. ++ +Default: false +quorum.initialQuorumSize:: +When `quorum.enabled=true`, set the initial quorum size. +Applies only when `requiredGroups` are provided and then only to those groups. ++ +Default: none - broker default will apply. routingKeyExpression:: A SpEL expression to determine the routing key to use when publishing messages. For a fixed routing key, use a literal expression, such as `routingKeyExpression='my.routingKey'` in a properties file or `routingKeyExpression: '''my.routingKey'''` in a YAML file. @@ -900,4 +965,4 @@ added after the original pull request but before a merge. if you are fixing an existing issue please add `Fixes gh-XXXX` at the end of the commit message (where XXXX is the issue number). -// ====================================================================================== +// ====================================================================================== \ No newline at end of file diff --git a/docs/pom.xml b/docs/pom.xml index 09e06b1ae..b095115b6 100644 --- a/docs/pom.xml +++ b/docs/pom.xml @@ -7,7 +7,7 @@ org.springframework.cloud spring-cloud-stream-binder-rabbit-parent - 3.0.0.BUILD-SNAPSHOT + 3.0.0.RELEASE pom spring-cloud-stream-binder-rabbit-docs diff --git a/pom.xml b/pom.xml index 6c0e414a5..c67f59d8e 100644 --- a/pom.xml +++ b/pom.xml @@ -2,16 +2,16 @@ 4.0.0 spring-cloud-stream-binder-rabbit-parent - 3.0.0.BUILD-SNAPSHOT + 3.0.0.RELEASE pom org.springframework.cloud spring-cloud-build - 2.2.0.BUILD-SNAPSHOT + 2.2.0.RELEASE - 3.0.0.BUILD-SNAPSHOT + 3.0.0.RELEASE 1.8 true true diff --git a/spring-cloud-starter-stream-rabbit/pom.xml b/spring-cloud-starter-stream-rabbit/pom.xml index 70405d4aa..4771cc37a 100644 --- a/spring-cloud-starter-stream-rabbit/pom.xml +++ b/spring-cloud-starter-stream-rabbit/pom.xml @@ -4,7 +4,7 @@ org.springframework.cloud spring-cloud-stream-binder-rabbit-parent - 3.0.0.BUILD-SNAPSHOT + 3.0.0.RELEASE spring-cloud-starter-stream-rabbit Spring Cloud Starter Stream Rabbit diff --git a/spring-cloud-stream-binder-rabbit-core/pom.xml b/spring-cloud-stream-binder-rabbit-core/pom.xml index 0d7a17ce9..0c2cee431 100644 --- a/spring-cloud-stream-binder-rabbit-core/pom.xml +++ b/spring-cloud-stream-binder-rabbit-core/pom.xml @@ -10,7 +10,7 @@ org.springframework.cloud spring-cloud-stream-binder-rabbit-parent - 3.0.0.BUILD-SNAPSHOT + 3.0.0.RELEASE diff --git a/spring-cloud-stream-binder-rabbit-test-support/pom.xml b/spring-cloud-stream-binder-rabbit-test-support/pom.xml index bae3a583f..52b1db89b 100644 --- a/spring-cloud-stream-binder-rabbit-test-support/pom.xml +++ b/spring-cloud-stream-binder-rabbit-test-support/pom.xml @@ -4,7 +4,7 @@ org.springframework.cloud spring-cloud-stream-binder-rabbit-parent - 3.0.0.BUILD-SNAPSHOT + 3.0.0.RELEASE spring-cloud-stream-binder-rabbit-test-support Rabbit related test classes diff --git a/spring-cloud-stream-binder-rabbit/pom.xml b/spring-cloud-stream-binder-rabbit/pom.xml index df8f4dd8a..01d662433 100644 --- a/spring-cloud-stream-binder-rabbit/pom.xml +++ b/spring-cloud-stream-binder-rabbit/pom.xml @@ -10,7 +10,7 @@ org.springframework.cloud spring-cloud-stream-binder-rabbit-parent - 3.0.0.BUILD-SNAPSHOT + 3.0.0.RELEASE