package com.yoho.datasync.producer.common.entity;

import lombok.Data;

import java.util.Map;

@Data
public class MqMessageEntity {
    /**
     * binlog操作类型，新增，删除等
     */
    private String action;

    private String dbName;

    private String tableName;

    /**
     * 版本号
     */
    private long version;

    private Map<String, Object> data;

    public MqMessageEntity(String action, String dbName, String tableName, long version, Map<String, Object> data) {
        this.action = action;
        this.dbName = dbName;
        this.tableName = tableName;
        this.version = version;
        this.data = data;
    }
}