企业微信推送

src/main/java/cn/van/business/mq/MessageConsumerService.java

@@ -31,11 +31,15 @@ public class MessageConsumerService implements RocketMQListener<JSONObject> {
 
     private static final Logger logger = LoggerFactory.getLogger(MessageConsumerService.class);
 
-    @Autowired
-    private WxtsUtil wxtsUtil;
+    private final WxtsUtil wxtsUtil;
     // create a rate limiter of 1 qps
     RateLimiter rateLimiter = RateLimiter.create(0.5);
 
+    @Autowired
+    public MessageConsumerService(WxtsUtil wxtsUtil) {
+        this.wxtsUtil = wxtsUtil;
+    }
+
     @Override
     public void onMessage(JSONObject jsonObject) {
         // 处理消息