From 7918cf2c69d2c2df92f58d7bf86ce8e505c92d84 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=99=88=E8=A3=95=E8=B4=A2?= <cyc58469@163.com>
Date: Sat, 28 Jan 2023 01:32:23 +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, 5 insertions(+), 3 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 9efdb167..61c181aa 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
@@ -47,14 +47,14 @@ public class CacheMessageListener implements MessageListener {
 	@Override
 	public void onMessage(Message message, byte[] pattern) {
 		try {
-			// TODO Auto-generated method stub 
 			String msg=message.toString();
-			logger.debug("消息下行开始----》"+msg);
+
 			//logger.debug(msg);
 			//心跳包
 			if("".equals(msg)||"\"\"".equals(msg)) {
 				return;
 			}
+			logger.debug("消息下行开始----》"+msg);
 			String channelName=stringSerializer.deserialize(pattern);
 			if(channelName.startsWith("XM_PRODUCT_CACHE")) {
 				xmProductCacheService.clearLocalCache(msg);
@@ -65,10 +65,12 @@ public class CacheMessageListener implements MessageListener {
 			}else if(channelName.startsWith("XM_GROUP_PRD_CACHE")) {
 				xmGroupCacheService.clearLocalProductCache(msg);
 			}
+			logger.debug("消息下行结束!!!!!!!!");
 		} catch (Exception e) {
 			logger.error("",e);
-		}finally {
 			logger.debug("消息下行结束!!!!!!!!");
+		}finally {
+
 		}
 		
 	}