fix: log error

asynkron · Dec 31, 2023 · 4c65054 · 4c65054
1 parent e5e9893
commit 4c65054
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/cluster/pubsub_delivery.go b/cluster/pubsub_delivery.go
@@ -46,9 +46,9 @@ func (p *PubSubMemberDeliveryActor) Receive(c actor.Context) {
 			identityLog := func(err error) {
 				if p.shouldThrottle() == actor.Open {
 					if fWithIdentity.identity.GetPid() != nil {
-						c.Logger().Info("Pub-sub message delivered to PID", slog.String("pid", fWithIdentity.identity.GetPid().String()))
+						c.Logger().Error("Pub-sub message failed to deliver to PID", slog.String("pid", fWithIdentity.identity.GetPid().String()), slog.Any("error", err))
 					} else if fWithIdentity.identity.GetClusterIdentity() != nil {
-						c.Logger().Info("Pub-sub message delivered to cluster identity", slog.String("cluster identity", fWithIdentity.identity.GetClusterIdentity().String()))
+						c.Logger().Error("Pub-sub message failed to deliver to cluster identity", slog.String("cluster identity", fWithIdentity.identity.GetClusterIdentity().String()), slog.Any("error", err))
 					}
 				}
 			}