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 { 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;