Add consumer name property (#203)

Gsantomaggio · web-flow · commit ce2e8475cb2c · 2022-12-21T12:22:23.000+01:00
- Add the consumer name property.
- Property is needed anyway, no only in case of super stream

Signed-off-by: Gabriele Santomaggio &lt;G.santomaggio@gmail.com&gt;
diff --git a/RabbitMQ.Stream.Client/RawConsumer.cs b/RabbitMQ.Stream.Client/RawConsumer.cs
@@ -215,9 +215,14 @@ private async Task Init()
             }
 
             var consumerProperties = new Dictionary<string, string>();
-            if (_config.IsSingleActiveConsumer)
+
+            if (!string.IsNullOrEmpty(_config.Reference))
             {
                 consumerProperties["name"] = _config.Reference;
+            }
+
+            if (_config.IsSingleActiveConsumer)
+            {
                 consumerProperties["single-active-consumer"] = "true";
                 if (!string.IsNullOrEmpty(_config.SuperStream))
                 {

Original file line number	Diff line number	Diff line change
`@@ -215,9 +215,14 @@ private async Task Init()`
`215`	`215`	`}`
`216`	`216`
`217`	`217`	`var consumerProperties = new Dictionary<string, string>();`
`218`		`- if (_config.IsSingleActiveConsumer)`
	`218`	`+`
	`219`	`+ if (!string.IsNullOrEmpty(_config.Reference))`
`219`	`220`	`{`
`220`	`221`	`consumerProperties["name"] = _config.Reference;`
	`222`	`+ }`
	`223`	`+`
	`224`	`+ if (_config.IsSingleActiveConsumer)`
	`225`	`+ {`
`221`	`226`	`consumerProperties["single-active-consumer"] = "true";`
`222`	`227`	`if (!string.IsNullOrEmpty(_config.SuperStream))`
`223`	`228`	`{`