RocketMQ消息实体改造

admin

2019-11-02 5e8907f1797a0f2028ab0731755941cf9ff7fc08

RocketMQ消息实体改造

 fanli/src/main/java/com/yeshi/fanli/dto/mq/BaseMQMsgBody.java

New file
@@ -0,0 +1,19 @@
package com.yeshi.fanli.dto.mq;



import com.yeshi.fanli.util.Constant;



public abstract class BaseMQMsgBody {

    private boolean test;// 是否是测试



    public BaseMQMsgBody() {

        this.test = Constant.IS_TEST;

    }



    public boolean isTest() {

        return test;

    }



    public void setTest(boolean test) {

        this.test = test;

    }

}


 fanli/src/main/java/com/yeshi/fanli/dto/mq/order/OrderTopicTagEnum.java

New file
@@ -0,0 +1,5 @@
package com.yeshi.fanli.dto.mq.order;



public enum OrderTopicTagEnum {



}


 fanli/src/main/java/com/yeshi/fanli/dto/mq/user/UserTopicTagEnum.java

New file
@@ -0,0 +1,16 @@
package com.yeshi.fanli.dto.mq.user;



import com.yeshi.fanli.util.annotation.UserActive;



public enum UserTopicTagEnum {

    userAccount(UserActive.class);

    private final Class<?> clazz;



    private UserTopicTagEnum(Class<?> clazz) {

        this.clazz = clazz;

    }



    public Class<?> getClazz() {

        return this.clazz;

    }

}