From 98b861220bd94f348e7a559a1b6eaef185ce426b Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=99=88=E8=A3=95=E8=B4=A2?= Date: Sat, 28 Jan 2023 01:30:56 +0800 Subject: [PATCH] =?UTF-8?q?=E5=88=86=E5=B8=83=E5=BC=8F=E6=9C=AC=E5=9C=B0?= =?UTF-8?q?=E7=BC=93=E5=AD=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../xm/core/service/cache/sub/CacheMessageListener.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/xm-core/src/main/java/com/xm/core/service/cache/sub/CacheMessageListener.java b/xm-core/src/main/java/com/xm/core/service/cache/sub/CacheMessageListener.java index c07eee48..9efdb167 100644 --- a/xm-core/src/main/java/com/xm/core/service/cache/sub/CacheMessageListener.java +++ b/xm-core/src/main/java/com/xm/core/service/cache/sub/CacheMessageListener.java @@ -56,13 +56,13 @@ public class CacheMessageListener implements MessageListener { return; } String channelName=stringSerializer.deserialize(pattern); - if(channelName.startsWith("XM_PRODUCT")) { + if(channelName.startsWith("XM_PRODUCT_CACHE")) { xmProductCacheService.clearLocalCache(msg); - }else if(channelName.startsWith("XM_PROJECT")) { + }else if(channelName.startsWith("XM_PROJECT_CACHE")) { xmProjectCacheService.clearLocalCache(msg); - }else if(channelName.startsWith("XM_GROUP_PRJ")) { + }else if(channelName.startsWith("XM_GROUP_PRJ_CACHE")) { xmGroupCacheService.clearLocalPrjectCache(msg); - }else if(channelName.startsWith("XM_GROUP_PRD")) { + }else if(channelName.startsWith("XM_GROUP_PRD_CACHE")) { xmGroupCacheService.clearLocalProductCache(msg); } } catch (Exception e) {