rename messagepool ProtectMessages to ForEachPendingMessage

2021-07-20 09:23:36 +03:00
parent c47fce8d2d
commit 839b00ab40
2 changed files with 4 additions and 4 deletions
@@ -68,7 +68,7 @@ func MessagePool(lc fx.Lifecycle, mpp messagepool.Provider, ds dtypes.MetadataDS
 			return mp.Close()
 		},
 	})
-	protector.AddProtector(mp.ProtectMessages)
+	protector.AddProtector(mp.ForEachPendingMessage)
 	return mp, nil
 }