From ad3717d51c36c350fe3ffaaadb326229d9fa80c7 Mon Sep 17 00:00:00 2001 From: Parker Date: Tue, 29 Dec 2020 19:09:24 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96Redis=E4=BF=A1=E9=81=93?= =?UTF-8?q?=E8=AE=A2=E9=98=85=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../core/cache/pushsub/receiver/RedisPushSubReceiver.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/opsli-base-support/opsli-core/src/main/java/org/opsli/core/cache/pushsub/receiver/RedisPushSubReceiver.java b/opsli-base-support/opsli-core/src/main/java/org/opsli/core/cache/pushsub/receiver/RedisPushSubReceiver.java index f43ed67f..3c4ac33a 100644 --- a/opsli-base-support/opsli-core/src/main/java/org/opsli/core/cache/pushsub/receiver/RedisPushSubReceiver.java +++ b/opsli-base-support/opsli-core/src/main/java/org/opsli/core/cache/pushsub/receiver/RedisPushSubReceiver.java @@ -50,6 +50,9 @@ import java.util.concurrent.ConcurrentMap; @Configuration public class RedisPushSubReceiver extends BaseReceiver { + /** Spring Bean 前缀 */ + public static final String SPRING_PREFIX = "redisPushSub_"; + /** 监听信道 */ public static final String CHANNEL = "opsli"; @@ -90,7 +93,7 @@ public class RedisPushSubReceiver extends BaseReceiver { HANDLER_MAP.put(handler.getType(),handler); //将new出的对象放入Spring容器中 - defaultListableBeanFactory.registerSingleton(aClass.getSimpleName(), obj); + defaultListableBeanFactory.registerSingleton(SPRING_PREFIX+aClass.getSimpleName(), obj); //自动注入依赖 beanFactory.autowireBean(obj);