diff options
Diffstat (limited to 'resources/mq/server/message_queue.go')
| -rw-r--r-- | resources/mq/server/message_queue.go | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/resources/mq/server/message_queue.go b/resources/mq/server/message_queue.go index a4fcf14..88bfab6 100644 --- a/resources/mq/server/message_queue.go +++ b/resources/mq/server/message_queue.go @@ -138,6 +138,14 @@ func (app *Queue) consumeJob(shutdownChannel chan bool, waitGroup *sync.WaitGrou app.Conn.Bury(id, 1) } else { log.Println("seite synchronisiert") + mailArgs := []string{"-s 'Hugo: gospeladlershof.de'", "status@iamfabulous.de"} + if err = exec.Command("mail", mailArgs...).Run(); err != nil { + log.WithFields( + log.Fields{ + "error": err, + }, + ).Warn("cannot send mail") + } // Deleting the job from beanstalkd app.Conn.Delete(id) |