diff --git a/cmd/migrate/migrate.go b/cmd/migrate/migrate.go index b96049c80565c8a7cd899a6c4223eec71975fb84..bc732d16be439e0303f621e8324f26da4fb1c1c7 100644 --- a/cmd/migrate/migrate.go +++ b/cmd/migrate/migrate.go @@ -62,6 +62,7 @@ func Run() { // Handles incoming messages func processMessage(msg amqp091.Delivery, ch *amqp091.Channel, veleroClient *veleroClientset.Clientset) { log.Println("Message received:") + fmt.Println(" Msg Body: ", msg.Body) var migrationMsg rabbitmq.MigrationMsg if err := yaml.Unmarshal(msg.Body, &migrationMsg); err != nil { log.Printf("Error parsing message: %v", err)