增加优化内容及提示

duxinglangzi

2022-08-16 cf3e03c1f621f6dd3e0f60827f8e415cec56353d

增加优化内容及提示

 src/main/java/com/duxinglangzi/canal/starter/configuration/CanalListenerEndpointRegistrar.java

@@ -57,7 +57,7 @@
            throw new IllegalArgumentException("@CanalListener Method Parameter Type Invalid, " +

                    "Need Parameter Type [ com.duxinglangzi.canal.starter.mode.CanalMessage ] please check ");

        if (StringUtils.isNotBlank(getDestination()) && !sets.contains(getDestination()))

            throw new CanalClientException("@CanalListener Illegal destination , please check ");

            throw new CanalClientException("@CanalListener Illegal destination  " + getDestination() + ", please check ");



    }




 src/main/java/com/duxinglangzi/canal/starter/mode/CanalMessage.java

@@ -6,22 +6,12 @@

/**
 * 监听事件的 返回信息, 主要将 CanalEntry 里不同层级的常用数据组装到同一层级使用.<p>
 * headers 是为了方便获取其他数据，比如
 * entryHeader 是为了方便获取其他数据，比如: 获取日志文件名、日志文件偏移量等
 *
 * @author wuqiong 2022/8/15
 */
public class CanalMessage implements Serializable {
    private static final long serialVersionUID = 730485362580815032L;

    /**
     * 数据库名
     */
    private String dataBaseName;

    /**
     * 表名
     */
    private String tableName;

    /**
     * 发生变化的 事件类型
@@ -50,16 +40,20 @@
        this.entryHeader = entryHeader;
        this.eventType = eventType;
        this.rowData = rowData;
        this.dataBaseName = getEntryHeader().getSchemaName();
        this.tableName = getEntryHeader().getTableName();
    }

    /**
     * 数据库名
     */
    public String getDataBaseName() {
        return dataBaseName;
        return getEntryHeader().getSchemaName();
    }

    /**
     * 表名
     */
    public String getTableName() {
        return tableName;
        return getEntryHeader().getTableName();
    }

    public CanalEntry.EventType getEventType() {