AddSendAttempt configures a Message for sending
(timestamp time.Time)
| 218 | |
| 219 | // AddSendAttempt configures a Message for sending |
| 220 | func (message *Message) AddSendAttempt(timestamp time.Time) *Message { |
| 221 | message.Status = MessageStatusSending |
| 222 | message.LastAttemptedAt = ×tamp |
| 223 | message.updateOrderTimestamp(timestamp) |
| 224 | return message |
| 225 | } |
| 226 | |
| 227 | func (message *Message) updateOrderTimestamp(timestamp time.Time) { |
| 228 | if timestamp.UnixNano() > message.OrderTimestamp.UnixNano() { |
no test coverage detected