Fix tracking check

acogoluegnes · acogoluegnes · commit 5b0e46322df0 · 2025-09-22T17:41:11.000+02:00
Conflicts:
	src/main/java/com/rabbitmq/stream/impl/StreamConsumer.java
diff --git a/src/main/java/com/rabbitmq/stream/impl/StreamConsumer.java b/src/main/java/com/rabbitmq/stream/impl/StreamConsumer.java
@@ -443,8 +443,8 @@ boolean sacActive() {
 
   boolean canTrack() {
     // closing is OK e.g. when flushing on closing
-    return ((this.state() == OPENING || this.state() == OPEN || this.state() == CLOSING)
-            || (this.trackingClient == null && this.state() == RECOVERING))
+    return (this.state() == OPENING || this.state() == OPEN || this.state() == CLOSING)
+        && (this.trackingClient != null && this.state() != RECOVERING)
         && this.name != null;
   }
 

Original file line number	Diff line number	Diff line change
`@@ -443,8 +443,8 @@ boolean sacActive() {`
`443`	`443`
`444`	`444`	`boolean canTrack() {`
`445`	`445`	`// closing is OK e.g. when flushing on closing`
`446`		`- return ((this.state() == OPENING \|\| this.state() == OPEN \|\| this.state() == CLOSING)`
`447`		`- \|\| (this.trackingClient == null && this.state() == RECOVERING))`
	`446`	`+ return (this.state() == OPENING \|\| this.state() == OPEN \|\| this.state() == CLOSING)`
	`447`	`+ && (this.trackingClient != null && this.state() != RECOVERING)`
`448`	`448`	`&& this.name != null;`
`449`	`449`	`}`
`450`	`450`