Fix tracking check

acogoluegnes · acogoluegnes · commit d688ccab8d6b · 2025-09-22T17:21:41.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
@@ -445,8 +445,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
`@@ -445,8 +445,8 @@ boolean sacActive() {`
`445`	`445`
`446`	`446`	`boolean canTrack() {`
`447`	`447`	`// closing is OK e.g. when flushing on closing`
`448`		`- return ((this.state() == OPENING \|\| this.state() == OPEN \|\| this.state() == CLOSING)`
`449`		`- \|\| (this.trackingClient == null && this.state() == RECOVERING))`
	`448`	`+ return (this.state() == OPENING \|\| this.state() == OPEN \|\| this.state() == CLOSING)`
	`449`	`+ && (this.trackingClient != null && this.state() != RECOVERING)`
`450`	`450`	`&& this.name != null;`
`451`	`451`	`}`
`452`	`452`