diff --git a/backend/database/pubsub.go b/backend/database/pubsub.go index 7f647cda..444ce91a 100644 --- a/backend/database/pubsub.go +++ b/backend/database/pubsub.go @@ -58,9 +58,9 @@ func (r *Redis) subscribe(ctx context.Context, consume ConsumeFunc, channel ...s } done <- nil case <-tick.C: - //fmt.Printf("ping message \n") if err := psc.Ping(""); err != nil { - done <- err + fmt.Printf("ping message error: %s \n", err) + //done <- err } case err := <-done: close(done)