Browse Source

Fix checkpoint status for message taking long warnings

Tulir Asokan 3 years ago
parent
commit
14581a314e
1 changed files with 3 additions and 0 deletions
  1. 3 0
      messagetracking.go

+ 3 - 0
messagetracking.go

@@ -195,6 +195,9 @@ func (portal *Portal) sendMessageMetrics(evt *event.Event, err error, part strin
 		portal.log.Logfln(level, "%s %s %s from %s: %v", part, msgType, evtDescription, evt.Sender, err)
 		reason, isCertain, _, sendNotice := errorToStatusReason(err)
 		status := bridge.ReasonToCheckpointStatus(reason)
+		if errors.Is(err, errMessageTakingLong) {
+			status = bridge.MsgStatusWillRetry
+		}
 		portal.bridge.SendMessageCheckpoint(evt, bridge.MsgStepRemote, err, status, ms.getRetryNum())
 		if sendNotice {
 			ms.setNoticeID(portal.sendErrorMessage(err, isCertain, ms.getNoticeID()))