消息

yujian

2020-06-29 af77c28ecf77d3ef50cb3b1f08840cc85378510d

消息

 fanli/src/main/java/com/yeshi/fanli/util/rocketmq/consumer/redpack/RedPackMessageListener.java

@@ -58,9 +58,9 @@
                    LogHelper.errorDetailInfo(e);

                }

                

                // 发送48小时延时消息

                boolean verifyOrder = redPackWinInviteService.verifyOrder(mqMsg.getUid(), mqMsg.getOrderId(), mqMsg.getType(), mqMsg.getPlaceTime());

                if (verifyOrder) {

                    // 发送48小时延时消息

                    int hour = 48;

                    if (Constant.IS_TEST) {

                        hour = 1;


 fanli/src/main/resource/rocket/consumer.xml

@@ -338,7 +338,35 @@








    <!-- 红包消息订阅 -->

     <bean id="redPackMessageListener"

             class="com.yeshi.fanli.util.rocketmq.consumer.redpack.RedPackMessageListener"></bean>

     <!-- Group ID 订阅同一个 Topic，可以创建多个 ConsumerBean -->

     <bean id="redPackConsumer" class="com.aliyun.openservices.ons.api.bean.ConsumerBean"

             init-method="start" destroy-method="shutdown">

          <property name="properties"> <!--消费者配置信息 -->

              <props>

                  <prop key="AccessKey">${rocketmq.AccessKey}</prop>

                  <prop key="SecretKey">${rocketmq.SecretKey}</prop>

                  <prop key="GROUP_ID">GID_RED_PACK</prop>

                  <prop key="NAMESRV_ADDR">${rocketmq.NAMESRV_ADDR}</prop>

                  <prop key="ConsumeThreadNums">50</prop>

              </props>

          </property>

          <property name="subscriptionTable">

              <map>

                 <!-- 产生订单/延时，订单到账 -->

                 <entry value-ref="redPackMessageListener">

                    <key>

                       <bean class="com.aliyun.openservices.ons.api.bean.Subscription">

                         <property name="topic" value="TOPIC_ORDER" />

                         <property name="expression"  value="orderStatistic||orderStatisticDelay" />

                       </bean>

                    </key>

                 </entry>

              </map>

          </property>

   </bean>