diff --git a/packages/relayer/pkg/queue/rabbitmq/queue.go b/packages/relayer/pkg/queue/rabbitmq/queue.go index a07298a215..b1f5c6e74c 100644 --- a/packages/relayer/pkg/queue/rabbitmq/queue.go +++ b/packages/relayer/pkg/queue/rabbitmq/queue.go @@ -215,6 +215,7 @@ func (r *RabbitMQ) Notify(ctx context.Context, wg *sync.WaitGroup) error { r.Close(ctx) if err := r.connect(); err != nil { + slog.Error("error connecting to rabbitmq", "err", err.Error()) return err } @@ -229,6 +230,7 @@ func (r *RabbitMQ) Notify(ctx context.Context, wg *sync.WaitGroup) error { r.Close(ctx) if err := r.connect(); err != nil { + slog.Error("error connecting to rabbitmq", "err", err.Error()) return err }