|
|
@@ -64,9 +64,10 @@ public class SendService {
|
|
|
// brokerMessageLogMapper.changeBrokerMessageLogStatus(messageId, Constants.ORDER_SEND_SUCCESS, new Date());
|
|
|
} else {
|
|
|
//失败则进行具体的后续操作:重试 或者补偿等手段
|
|
|
- logger.error("msgId={},发送失败:{}", correlationData.getId(), cause);
|
|
|
BrokerMessagelog message = brokerMessageLogMapper.getMessage(correlationData.getId());
|
|
|
- // sendDelayMessage((MessageInfo) message.getMessage());
|
|
|
+ // sendDelayMessage((MessageInfo) message.getMessage());
|
|
|
+ logger.error("msgId={},发送失败:{}", correlationData.getId(), cause);
|
|
|
+
|
|
|
}
|
|
|
}
|
|
|
};
|