配送通知rocketmq

order-application-service/src/main/java/cn/freemud/amp/RocketMQConfig.java

 package cn.freemud.amp;
 
+import cn.freemud.constant.RocketMQConst;
 import com.alibaba.fastjson.support.spring.messaging.MappingFastJsonMessageConverter;
 import org.apache.rocketmq.acl.common.AclClientRPCHook;
 import org.apache.rocketmq.acl.common.SessionCredentials;
@@ -7,7 +8,6 @@ import org.apache.rocketmq.client.AccessChannel;
 import org.apache.rocketmq.client.producer.DefaultMQProducer;
 import org.apache.rocketmq.spring.autoconfigure.RocketMQProperties;
 import org.apache.rocketmq.spring.core.RocketMQTemplate;
-import org.springframework.beans.factory.annotation.Value;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.util.Assert;
@@ -18,15 +18,12 @@ import javax.annotation.Resource;
 @Configuration
 public class RocketMQConfig {
 
-    @Value("${producer_group_delivery:order_delivery_producer_group}")
-    private String PRODUCER_GROUP_DELIVERY;
-
     @Resource
     private RocketMQProperties rocketMQProperties;
 
     @Bean(name = "deliveryRocketMqTemplate", destroyMethod = "destroy")
     public RocketMQTemplate rocketMQTemplate() {
-        DefaultMQProducer defaultMQProducer = createMQProducer(PRODUCER_GROUP_DELIVERY);
+        DefaultMQProducer defaultMQProducer = createMQProducer(RocketMQConst.ORDER_THIRD_PUSH_PRODUCER_GROUP);
         RocketMQTemplate rocketMQTemplate = new RocketMQTemplate();
         rocketMQTemplate.setProducer(defaultMQProducer);
         rocketMQTemplate.setMessageConverter(new MappingFastJsonMessageConverter());

order-application-service/src/main/java/cn/freemud/amp/service/ProduceMQService.java

@@ -46,10 +46,10 @@ public class ProduceMQService {
      * @param deliveryRequest
      */
     public void sendRocketMqOfDeliveryInfo(CallbackUrlRequestDto deliveryRequest) {
-        Header header = new Header(MQAction.UPDATE.getAction(), "delivery/callbackUrl", deliveryRequest.getOrderId(), RocketMQConst.ORDER_DELIVERY_TOPIC);
+        Header header = new Header(MQAction.UPDATE.getAction(), "delivery/callbackUrl", deliveryRequest.getOrderId(), RocketMQConst.ORDER_THIRD_PUSH_TOPIC);
         MQMessage<CallbackUrlRequestDto> mqMessage = new MQMessage(header, deliveryRequest);
 
-        String destination = String.format("%s:%s", RocketMQConst.ORDER_DELIVERY_TOPIC, RocketMQConst.OrderSubsidiary.DELIVERY);
+        String destination = String.format("%s:%s", RocketMQConst.ORDER_THIRD_PUSH_TOPIC, RocketMQConst.OrderSubsidiaryTag.DELIVERY);
 
         Message message = MessageBuilder
                 .withPayload(mqMessage)

order-application-service/src/main/java/cn/freemud/constant/RocketMQConst.java

 package cn.freemud.constant;
 
 /**
- * @Description服务配置
+ * @Description RocketMQ服务配置
  * @mark topic 、producerGroup、consumerGroup 最大长度32
  */
 public class RocketMQConst {
-    // 配送Topic
-    public static final String ORDER_DELIVERY_TOPIC = "order.delivery.topic";
-    // 配送生产者名称
-    public static final String ORDER_DELIVERY_PRODUCER_GROUP = "order.delivery.producer";
 
-    // 订单附属业务推送开放平台topic
-    public static final String ORDER_SUBSIDIARY_TOPIC = "order.subsidiary.topic";
-    // 订单附属业务推送开放平台生产者名称
-    public static final String ORDER_SUBSIDIARY_PRODUCER_GROUP = "order.subsidiary.producer";
+    // 订单周边业务（配送、发票）推送开放平台topic
+    public static final String ORDER_THIRD_PUSH_TOPIC = "order.third.push.topic";
+    // 订单周边业务（配送、发票）推送开放平台生产者名称
+    public static final String ORDER_THIRD_PUSH_PRODUCER_GROUP = "order.third.push.producer";
 
-    // 订单原始消息topic
-    public static final String ORDER_ORIGIN_TOPIC = "order.origin.topic";
-    // 订单原始消息生产者名称
-    public static final String ORDER_ORIGIN_PRODUCER_GROUP = "order.origin.producer";
 
-    public enum OrderSubsidiary {
+    public enum OrderSubsidiaryTag {
         DELIVERY, INVOICE;
     }