Delivered registers a message as delivered
(timestamp time.Time)
| 178 | |
| 179 | // Delivered registers a message as delivered |
| 180 | func (message *Message) Delivered(timestamp time.Time) *Message { |
| 181 | message.DeliveredAt = ×tamp |
| 182 | message.Status = MessageStatusDelivered |
| 183 | if message.SendDuration == nil { |
| 184 | sendDuration := timestamp.UnixNano() - message.RequestReceivedAt.UnixNano() |
| 185 | message.SendDuration = &sendDuration |
| 186 | |
| 187 | } |
| 188 | message.updateOrderTimestamp(timestamp) |
| 189 | return message |
| 190 | } |
| 191 | |
| 192 | // AddSendAttemptCount increments the send attempt count of a message |
| 193 | func (message *Message) AddSendAttemptCount() *Message { |
no test coverage detected