log

taikoxyz · Mar 2, 2024 · 6f847a3 · 6f847a3
1 parent 2b17d99
commit 6f847a3
Showing 1 changed file with 2 additions and 0 deletions.
diff --git 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
 			}