Check version when version is not (#345)

* Check version when version is not set and is less than 3.11 * Reduce the log level for the exchange version --------- Signed-off-by: Gabriele Santomaggio <[email protected]>
rabbitmq · Jul 30, 2024 · e0bcf7e · e0bcf7e
1 parent e4f6b06
commit e0bcf7e
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 4 deletions.
diff --git a/pkg/stream/available_features.go b/pkg/stream/available_features.go
@@ -45,7 +45,7 @@ func (a *availableFeatures) BrokerFilterEnabled() bool {
 func (a *availableFeatures) IsBrokerSingleActiveConsumerEnabled() bool {
 	lock.Lock()
 	defer lock.Unlock()
-	return a.brokerSingleActiveConsumerEnabled == a.is311OrMore
+	return a.brokerSingleActiveConsumerEnabled
 }
 
 func (a *availableFeatures) SetVersion(version string) error {

diff --git a/pkg/stream/client.go b/pkg/stream/client.go
@@ -212,9 +212,13 @@ func (c *Client) connect() error {
 			return err2
 		}
 
-		logs.LogDebug("Server properties: %s", c.serverProperties)
-		if serverProperties["version"] == "" {
-			logs.LogInfo(
+		err = c.availableFeatures.SetVersion(serverProperties["version"])
+		if err != nil {
+			logs.LogWarn("Error checking server version: %s", err)
+		}
+
+		if serverProperties["version"] == "" || !c.availableFeatures.Is311OrMore() {
+			logs.LogDebug(
 				"Server version is less than 3.11.0, skipping command version exchange")
 		} else {
 			err := c.exchangeVersion(c.serverProperties["version"])