消息队列消息生产者统计

public class RabbitMQMsg implements Serializable {
    private static final long serialVersionUID = 1L;
    private String msgId;  //消息id
    private Object msgBody;  //消息本体
    private String createTime;  //创建时间
    private String source;  //来源
}

public class User implements Serializable {
    private static final long serialVersionUID = 1L;

    private Integer id;
    //用户id
    @TableId(type = IdType.ASSIGN_ID)
    private String userId;
    //账号
    private String account;
    //用户名称
    private String userName;
    //用户密码(已加密)
    private String password;
    //手机号
    private String mobile;
    //组织机构
    private String orgName;
    //备注
    private String remark;
    //创建人
    private String createUser;
    //创建时间
    @JsonFormat(pattern="yyyy-MM-dd HH:mm:ss",timezone = "GMT+8")
    @TableField(fill = FieldFill.INSERT)
    private Date createTime;
    //更新人
    private String updateUser;
    //更新时间
    @JsonFormat(pattern="yyyy-MM-dd HH:mm:ss",timezone = "GMT+8")
    @TableField(fill = FieldFill.UPDATE)
    private Date updateTime;

    private Integer isValid;
}