From 0b055a3f554da3a934e79e88c4781705cbab5a21 Mon Sep 17 00:00:00 2001
From: renxue <auster_i@163.com>
Date: 星期一, 24 十月 2022 11:40:26 +0800
Subject: [PATCH] 修改包下的类名
---
README.md | 16 ++++++++--------
1 files changed, 8 insertions(+), 8 deletions(-)
diff --git a/README.md b/README.md
index 2877874..94b83cb 100644
--- a/README.md
+++ b/README.md
@@ -28,11 +28,11 @@
import com.alibaba.otter.canal.protocol.CanalEntry;
-import com.duxinglangzi.canal.starter.annotation.CanalInsertListener;
-import com.duxinglangzi.canal.starter.annotation.CanalListener;
-import com.duxinglangzi.canal.starter.annotation.CanalUpdateListener;
-import com.duxinglangzi.canal.starter.annotation.EnableCanalListener;
-import com.duxinglangzi.canal.starter.mode.CanalMessage;
+import CanalInsertListener;
+import CanalListener;
+import CanalUpdateListener;
+import EnableCanalListener;
+import CanalMessage;
import org.springframework.stereotype.Service;
import java.util.stream.Collectors;
@@ -48,7 +48,7 @@
/**
* 蹇呴』鍦ㄧ被涓� 浣跨敤 EnableCanalListener 娉ㄨВ鎵嶈兘寮�鍚� canal listener
*
- * 鐩墠 Listener 鏂规硶鐨勫弬鏁板繀椤讳负 com.duxinglangzi.canal.starter.mode.CanalMessage
+ * 鐩墠 Listener 鏂规硶鐨勫弬鏁板繀椤讳负 CanalMessage
* 绋嬪簭鍦ㄥ惎鍔ㄨ繃绋嬩腑浼氬仛妫�鏌�
*/
@@ -107,9 +107,9 @@
CanalEntry.RowData rowData = message.getRowData();
- System.out.println(" >>>>>>>>>>>>>[褰撳墠鏁版嵁搴�: "+message.getDataBaseName()+" ," +
+ System.out.println(" >>>>>>>>>>>>>[褰撳墠鏁版嵁搴�: " + message.getDataBaseName() + " ," +
"鏁版嵁搴撹〃鍚�: " + message.getTableName() + " , " +
- "鏂规硶: " + method );
+ "鏂规硶: " + method);
if (eventType == CanalEntry.EventType.DELETE) {
rowData.getBeforeColumnsList().stream().collect(Collectors.toList()).forEach(ele -> {
--
Gitblit v1.8.0