Skip to content
Snippets Groups Projects
Commit d8f49d91 authored by Ignacio Prusiel Mariscal's avatar Ignacio Prusiel Mariscal
Browse files

Bugfixing

parent c443af6b
No related branches found
No related tags found
No related merge requests found
Pipeline #66804 passed with warnings
...@@ -62,6 +62,7 @@ func Run() { ...@@ -62,6 +62,7 @@ func Run() {
// Handles incoming messages // Handles incoming messages
func processMessage(msg amqp091.Delivery, ch *amqp091.Channel, veleroClient *veleroClientset.Clientset) { func processMessage(msg amqp091.Delivery, ch *amqp091.Channel, veleroClient *veleroClientset.Clientset) {
log.Println("Message received:") log.Println("Message received:")
fmt.Println(" Msg Body: ", msg.Body)
var migrationMsg rabbitmq.MigrationMsg var migrationMsg rabbitmq.MigrationMsg
if err := yaml.Unmarshal(msg.Body, &migrationMsg); err != nil { if err := yaml.Unmarshal(msg.Body, &migrationMsg); err != nil {
log.Printf("Error parsing message: %v", err) log.Printf("Error parsing message: %v", err)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment