Quite likely no need to quiescing multiple times

danielmarbach · danielmarbach · commit 43773989fc0c · 2025-08-21T22:27:57.000+02:00
diff --git a/projects/RabbitMQ.Client/ConsumerDispatching/ConsumerDispatcherChannelBase.cs b/projects/RabbitMQ.Client/ConsumerDispatching/ConsumerDispatcherChannelBase.cs
@@ -148,6 +148,11 @@ await _writer.WriteAsync(work, cancellationToken)
 
         public void Quiesce()
         {
+            if (IsQuiescing)
+            {
+                return;
+            }
+
             Interlocked.Exchange(ref _isQuiescing, 1);
             try
             {
@@ -212,12 +217,7 @@ protected bool IsQuiescing
         {
             get
             {
-                if (Interlocked.Read(ref _isQuiescing) == 1)
-                {
-                    return true;
-                }
-
-                return false;
+                return Interlocked.Read(ref _isQuiescing) == 1;
             }
         }
 

Original file line number	Diff line number	Diff line change
`@@ -148,6 +148,11 @@ await _writer.WriteAsync(work, cancellationToken)`
`148`	`148`
`149`	`149`	`public void Quiesce()`
`150`	`150`	`{`
	`151`	`+ if (IsQuiescing)`
	`152`	`+ {`
	`153`	`+ return;`
	`154`	`+ }`
	`155`	`+`
`151`	`156`	`Interlocked.Exchange(ref _isQuiescing, 1);`
`152`	`157`	`try`
`153`	`158`	`{`
`@@ -212,12 +217,7 @@ protected bool IsQuiescing`
`212`	`217`	`{`
`213`	`218`	`get`
`214`	`219`	`{`
`215`		`- if (Interlocked.Read(ref _isQuiescing) == 1)`
`216`		`- {`
`217`		`- return true;`
`218`		`- }`
`219`		`-`
`220`		`- return false;`
	`220`	`+ return Interlocked.Read(ref _isQuiescing) == 1;`
`221`	`221`	`}`
`222`	`222`	`}`
`223`	`223`