邀请码添加返回状态

yujian

2019-01-22 88b54772dbcf5ecab1e2316e4e4626ac901b8908

 fanli/src/main/java/com/yeshi/fanli/util/CMQManager.java

@@ -50,6 +50,17 @@
   public static String GOODS_UPDATE = "goods_update_queue";



   static {



      if (Constant.IS_TEST) {

         QUEUENAME_ORDER = "test-" + QUEUENAME_ORDER;

         EXTRACT_RESULT = "test-" + EXTRACT_RESULT;

         PUSH_IOS = "test-" + PUSH_IOS;

         FANLI_ORDER = "test-" + FANLI_ORDER;

         FANLI_ORDER_NEW = "test-" + FANLI_ORDER_NEW;

         FANLI_TICHENG_ORDER = "test-" + FANLI_TICHENG_ORDER;

         ORDER_WEIQUAN = "test-" + ORDER_WEIQUAN;

      }



      QUEUENAME_ORDER += "-" + Constant.systemCommonConfig.getProjectName();

      EXTRACT_RESULT += "-" + Constant.systemCommonConfig.getProjectName();

      PUSH_IOS += "-" + Constant.systemCommonConfig.getProjectName();

@@ -194,8 +205,7 @@
         }

      return map;

   }

	
	


   public Map<String, HongBaoV2> consumeFanLiMsgNew(int count) {

      List<Message> list = cmqUtil.recieveMsg(count, FANLI_ORDER_NEW);

      Map<String, HongBaoV2> map = new HashMap<>();

@@ -209,12 +219,11 @@
         }

      return map;

   }

	


   public void deleteFanLiMsg(String receiptHandle) {

      cmqUtil.deleteMsg(FANLI_ORDER, receiptHandle);

   }

	


   public void deleteFanLiMsgNew(String receiptHandle) {

      cmqUtil.deleteMsg(FANLI_ORDER_NEW, receiptHandle);

   }