-
Notifications
You must be signed in to change notification settings - Fork 300
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Start Rabbitmq documentation and upgrade guide
- Loading branch information
1 parent
0a09e49
commit 2bdb34a
Showing
4 changed files
with
40 additions
and
0 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Empty file.
20 changes: 20 additions & 0 deletions
20
transports/rabbitmq/connection-settings_management-api-url_rabbit_[10,).partial.md
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,20 @@ | ||
## Configuring RabbitMQ delivery limit check | ||
|
||
> [!NOTE] | ||
> RabbitMQ version 4.0 and above sets a default delivery limit value of 20 messages on queue creation. Setting the delivery limit to unlimited (-1) is critical for the proper functioning of the NServiceBus recoverability process. Ensure that this setting is configured in your RabbitMQ node if the check is disabled. | ||
The transport can verify that the RabbitMQ delivery limit is set to unlimited (-1) using the management API. This ensures that the NServiceBus recoverability process works correctly, preventing potential message loss. For this check to function, the RabbitMQ management plugin must be enabled on the RabbitMQ node. | ||
|
||
To configure the HTTP client and perform the delivery limit check, set the authentication details as follows: | ||
|
||
```csharp | ||
var transport = new RabbitMQTransport(RoutingTopology.Conventional(QueueType.Quorum), "host=localhost") | ||
{ | ||
ManagementApiUrl = "http://username:password@localhost:15672"; | ||
} | ||
|
||
// Or | ||
var transport = endpointConfiguration.UseTransport<RabbitMQTransport>(); | ||
transport.ManagementApiUrl("http://username:password@localhost:15672"); | ||
``` |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters