rcoketmq集中管理

admin

2020-07-01 c54fb6a88876be994906d57d2d18e844686964d0

 fanli/src/main/java/com/yeshi/fanli/dto/mq/user/body/UserCloudMQMsg.java

@@ -9,10 +9,21 @@
 *

 */

public class UserCloudMQMsg extends BaseMQMsgBody {

	
   public final static int TYPE_STORE = 1; // 商品库

   public final static int TYPE_EVALUATE = 2; // 发圈内容

   public final static int TYPE_PUSH = 3; // 站内推送消息

	
   private Long uid;// 用户ID

   private String id;// 发圈id 、 商品库id

   private Integer type;// 类型



   public UserCloudMQMsg(Long uid, Integer type) {

      super();

      this.uid = uid;

      this.type = type;

   }

	
   public UserCloudMQMsg(Long uid, String id, Integer type) {

      super();

      this.uid = uid;