diff --git a/executors/rabbitmq/rabbitmq.go b/executors/rabbitmq/rabbitmq.go
index 1e367ea3..baead3dc 100644
--- 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
 		}