diff --git a/cmd/backoffice/main.go b/cmd/backoffice/main.go
index 50df960..7ee7975 100644
--- a/cmd/backoffice/main.go
+++ b/cmd/backoffice/main.go
@@ -75,7 +75,8 @@ func startMutationConsumer(ctx context.Context, conn *amqp.Connection, hub *Hub)
 				return
 			case m, ok := <-msgs:
 				if !ok {
-					return
+					log.Print("no message")
+					continue
 				}
 				// Log and broadcast to all websocket clients
 				log.Printf("mutation event: %s", string(m.Body))