summaryrefslogtreecommitdiff
path: root/resources/mq/server/message_queue.go
diff options
context:
space:
mode:
authorhorus_arch2016-12-13 19:42:50 +0100
committerhorus_arch2016-12-13 19:42:50 +0100
commit34e350dfcecc3757378c6ea4d3438ade52fbd88d (patch)
treeec4789e0ba3f39bdb28cbadf727e8f8f8ae5558b /resources/mq/server/message_queue.go
parente751f3e71969d2976eaa1e3f57a8c07b5c789e88 (diff)
downloadgospeladlershof.de-34e350dfcecc3757378c6ea4d3438ade52fbd88d.tar.gz
PHP sendet jetzt keine E-Mail mehr.
Diffstat (limited to 'resources/mq/server/message_queue.go')
-rw-r--r--resources/mq/server/message_queue.go8
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)