Configure shovels to wait until all sources and destinations are declared (backport #11793) #11823
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Proposed Changes
it addresses feature request #10501
Doc's PR => rabbitmq/rabbitmq-website#1987
Dynamic shovels
You can configure the plugin to either always declare the missing source and/or destination queues or instead wait until they are declared, for instance, once the definitions file is imported at node boot up. In the latter case, shovel will try to passively declare the resource until it succeeds. It uses the reconnection_delay to wait between attempts.
To configure the plugin to wait until the resources are available, apply the following configuration to
rabbitmq.conf
:To configure individual shovels to wait until either the source and/or destination are available, apply these key-pair values to the shovel parameter:
Shovel parameters take precedence over plugin configuration values.
Static shovels
Static shovels wait until the queue exists provided it is configured with
shovel.topology.predeclared = true
and the shovel'ssource
has nodeclarations
or it is empty.Types of Changes
What types of changes does your code introduce to this project?
Put an
x
in the boxes that applyThis is an automatic backport of pull request #11793 done by [Mergify](https://mergify.com).