|
|
|
@ -83,7 +83,6 @@ public class OrderMqMessageRecordServiceImpl implements OrderMqMessageRecordServ |
|
|
|
OrderMqMessageRecord orderMqMessageRecord = saveMessageRecord(topic,tag, message); |
|
|
|
//发消息
|
|
|
|
OrderMqLocalRecordMessage mqLocalMessage = EntityConvertUtil.copy(orderMqMessageRecord, OrderMqLocalRecordMessage.class); |
|
|
|
mqLocalMessage.setRetryTimes(0); |
|
|
|
mqLocalMessage.setSource(ServiceNameConstants.ORDER_SERVICE); |
|
|
|
rocketMQTemplate.asyncSend(rocketMQEnhanceTemplate.buildDestination(topic,tag), MessageBuilder.withPayload(mqLocalMessage).build(), new SendCallback() { |
|
|
|
@Override |
|
|
|
|