Skip to content

Commit 491a3db

Browse files
Update email.go
1 parent 02da111 commit 491a3db

File tree

1 file changed

+13
-0
lines changed

1 file changed

+13
-0
lines changed

internal/messenger/email/email.go

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -190,6 +190,19 @@ func (e *Emailer) Flush() error {
190190
return nil
191191
}
192192

193+
// Retrieve the retry delay from the configuration
194+
retryDelay := time.Duration(config.RetryDelay) * time.Second
195+
196+
// Implement retry logic
197+
var err error
198+
for i := 0; i < maxRetries; i++ {
199+
err = sendSMTPMail(...)
200+
if err == nil {
201+
break
202+
}
203+
time.Sleep(retryDelay) // Wait for the retry delay before the next attempt
204+
}
205+
193206
// Close closes the SMTP pools.
194207
func (e *Emailer) Close() error {
195208
for _, s := range e.servers {

0 commit comments

Comments
 (0)