AMQP-1. consumer: only set consumer priority when > 0

rabbitmq · Jan 16, 2025 · 3b5f05d · 3b5f05d
1 parent 61dd7ee
commit 3b5f05d
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/pkg/amqp10/consumer.go b/pkg/amqp10/consumer.go
@@ -253,8 +253,10 @@ func (c *Amqp10Consumer) Stop(reason string) {
 }
 
 func buildLinkProperties(cfg config.Config) map[string]any {
-	props := map[string]any{
-		"rabbitmq:priority": cfg.ConsumerPriority,
+	props := map[string]any{}
+
+	if cfg.ConsumerPriority != 0 {
+		props["rabbitmq:priority"] = cfg.ConsumerPriority
 	}
 
 	return props