pick

src/main/java/com/qmrb/system/mq/PickCarProducer.java

@@ -68,6 +68,9 @@ public class PickCarProducer {
         Message message = new Message(topic, tags, body.getBytes(RemotingHelper.DEFAULT_CHARSET));
         StopWatch stop = new StopWatch();
         stop.start();
+        if(producer == null){
+            defaultMQProducer();
+        }
         SendResult result = producer.send(message);
         log.info("发送响应：MsgId:" + result.getMsgId() + "，发送状态:" + result.getSendStatus());
         stop.stop();