From 13b3d11e5e292ac1fd28a40c1889e20d5e8c5f56 Mon Sep 17 00:00:00 2001
From: xsx <825657193@qq.com>
Date: Mon, 29 Dec 2025 17:12:43 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20redis=E9=9B=86=E7=BE=A4=E8=8E=B7?=
 =?UTF-8?q?=E5=8F=96=E7=89=88=E6=9C=AC=E5=BC=82=E5=B8=B8=E7=9A=84bug?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/main/java/com/bx/imcommon/mq/RedisMQTemplate.java  | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/im-common/src/main/java/com/bx/imcommon/mq/RedisMQTemplate.java b/im-common/src/main/java/com/bx/imcommon/mq/RedisMQTemplate.java
index dbb927b..f81c8d4 100644
--- a/im-common/src/main/java/com/bx/imcommon/mq/RedisMQTemplate.java
+++ b/im-common/src/main/java/com/bx/imcommon/mq/RedisMQTemplate.java
@@ -20,7 +20,12 @@ public class RedisMQTemplate extends RedisTemplate<String, Object> {
         if (version.isEmpty()) {
             RedisConnection connection = RedisConnectionUtils.getConnection(getConnectionFactory());
             Properties properties = connection.info();
-            version = properties.getProperty("redis_version");
+            for (String key : properties.stringPropertyNames()) {
+                if (key.contains("redis_version")) {
+                    version = properties.getProperty(key);
+                    break;
+                }
+            }
             RedisConnectionUtils.releaseConnection(connection,getConnectionFactory());
         }
         return version;