Fix tracking check

acogoluegnes · acogoluegnes · commit f8823b89d18a · 2025-09-22T16:50:11.000+02:00
diff --git a/src/main/java/com/rabbitmq/stream/impl/StreamConsumer.java b/src/main/java/com/rabbitmq/stream/impl/StreamConsumer.java
@@ -444,9 +444,8 @@ boolean sacActive() {
   }
 
   boolean canTrack() {
-    // FIXME check the condition to be able to track
-    return ((this.state() == OPENING || this.state() == OPEN)
-            || (this.trackingClient == null && this.state() == RECOVERING))
+    return (this.state() == OPENING || this.state() == OPEN)
+        && (this.trackingClient != null && this.state() != RECOVERING)
         && this.name != null;
   }
 

Original file line number	Diff line number	Diff line change
`@@ -444,9 +444,8 @@ boolean sacActive() {`
`444`	`444`	`}`
`445`	`445`
`446`	`446`	`boolean canTrack() {`
`447`		`- // FIXME check the condition to be able to track`
`448`		`- return ((this.state() == OPENING \|\| this.state() == OPEN)`
`449`		`- \|\| (this.trackingClient == null && this.state() == RECOVERING))`
	`447`	`+ return (this.state() == OPENING \|\| this.state() == OPEN)`
	`448`	`+ && (this.trackingClient != null && this.state() != RECOVERING)`
`450`	`449`	`&& this.name != null;`
`451`	`450`	`}`
`452`	`451`