fanli-server.git

			@@ -5,7 +5,6 @@
			import com.yeshi.fanli.entity.bus.user.Order;
			import com.yeshi.fanli.util.Constant;
			import com.yeshi.fanli.util.mq.cmq.TDMQUtil;
			import org.yeshi.utils.CMQUtil;

			import java.util.HashMap;
			import java.util.List;
			@@ -16,7 +15,6 @@
			private static String secretId = "AKIDTlpgJhLjOozvd6QI2XnpfGbgV4NQJk25";
			private static String secretKey = "xhCSUHo55oHUQ6XicFcmfIgspX0EEzWo";
			private static PlaceOrderCMQManager placeOrderCMQManager;
			private static CMQUtil cmqUtil;

			private final static String TOPIC_NAME = "topic_place_order";

			@@ -27,7 +25,6 @@
			public static String SUBSCRIBE_INTEGRAL = "integral";

			static {
			cmqUtil = CMQUtil.getInstance(secretId, secretKey);
			TDMQUtil.getInstance().init(secretId, secretKey, Constant.TDMQ_PUBLIC);

			// 创建主题，添加订阅
			@@ -75,7 +72,7 @@
			* @return
			*/
			public Map<String, Order> consumeQueueMsg(String queueName, int count) {
			List<Message> list = Constant.TDMQ_CONSUMER ? TDMQUtil.getInstance().recieveMsg(count, queueName) : cmqUtil.recieveMsg(count, queueName);
			List<Message> list = TDMQUtil.getInstance().recieveMsg(count, queueName);
			Map<String, Order> map = new HashMap<>();

			if (list != null)
			@@ -88,11 +85,9 @@
			}

			public void deleteQueueMsg(String queueName, String receiptHandle) {
			if (Constant.TDMQ_CONSUMER) {
			TDMQUtil.getInstance().deleteMsg(queueName, receiptHandle);
			} else {
			cmqUtil.deleteMsg(queueName, receiptHandle);
			}

			TDMQUtil.getInstance().deleteMsg(queueName, receiptHandle);

			}

			}