Nail/fission-src
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix nats trigger replies message to non-existing resptopic (#260)

Browse Source
This commit is contained in:
Ta-Ching Chen
2017-07-26 11:43:23 -07:00
committed by Soam Vasani
parent 2036d80778
commit a8fc7a7029
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
mqtrigger/messageQueue/nats.go
+6 -3
View File
@@ -128,9 +128,12 @@ func msgHandler(nats *Nats, trigger fission.MessageQueueTrigger) func(*ns.Msg) {
if err != nil { if err != nil {
log.Warningf("Failed to ack message: %v", err) log.Warningf("Failed to ack message: %v", err)
} }
err = nats.nsConn.Publish(trigger.ResponseTopic, body)
if err != nil { if len(trigger.ResponseTopic) > 0 {
log.Warningf("Failed to publish message to topic %s: %v", trigger.ResponseTopic, err) err = nats.nsConn.Publish(trigger.ResponseTopic, body)
if err != nil {
log.Warningf("Failed to publish message to topic %s: %v", trigger.ResponseTopic, err)
}
} }
} }
} }