Merge pull request #5 from tp-tc/error-on-connect-failure

Propagate the error on connect failure.
taskcluster · Apr 21, 2020 · 515edd0 · 515edd0
2 parents 79f6799 + 68b8db3
commit 515edd0
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/pulse/pulse.go b/pulse/pulse.go
@@ -238,7 +238,9 @@ func (c *Connection) Consume(
 
 	// TODO: this needs to be synchronised
 	if !c.connected {
-		c.connect()
+		if err := c.connect(); err != nil {
+			return pulseQueue, Error(err, "Failed to connect to pulse")
+		}
 	}
 
 	ch, err := c.AMQPConn.Channel()