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

2017-07-26 11:43:23 -07:00
parent b052e67e9f
commit e1ec460da8
1 changed files with 6 additions and 3 deletions
@@ -128,9 +128,12 @@ func msgHandler(nats *Nats, trigger fission.MessageQueueTrigger) func(*ns.Msg) {
 		if err != nil {
 			log.Warningf("Failed to ack message: %v", err)
 		}
-		err = nats.nsConn.Publish(trigger.ResponseTopic, body)
-		if err != nil {
-			log.Warningf("Failed to publish message to topic %s: %v", trigger.ResponseTopic, err)
+
+		if len(trigger.ResponseTopic) > 0 {
+			err = nats.nsConn.Publish(trigger.ResponseTopic, body)
+			if err != nil {
+				log.Warningf("Failed to publish message to topic %s: %v", trigger.ResponseTopic, err)
+			}
 		}
 	}
 }