fix(rabbitmq-rpc): Fix channel initialization for message publishing. (…

…ovh#809) * fix(rabbitmq-rpc): Fix channel initialization for message publishing. Signed-off-by: Tomaž Završnik <[email protected]>
09bassOp · Aug 30, 2024 · aae6f3a · aae6f3a
1 parent 5e480f0
commit aae6f3a
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/executors/rabbitmq/rabbitmq.go b/executors/rabbitmq/rabbitmq.go
@@ -157,7 +157,8 @@ func (e Executor) publishMessages(ctx context.Context, workdir string, connectio
 	var ch *amqp.Channel
 	var err error
 	if connection == nil || channel == nil {
-		ch, conn, err := e.openChannel(ctx)
+		var conn *amqp.Connection
+		conn, ch, err = e.openChannel(ctx)
 		if err != nil {
 			return err
 		}