v0.5.0
Minor Changes
-
ca3726fThanks @cevr! - Addflushandredelivermethods to entity ActorObject.actor.flush(actorId)— delete all messages and replies viaMessageStorage.clearAddressactor.redeliver(actorId)— clear read leases so messages re-enter polling viaMessageStorage.resetAddress
Both require
MessageStorage | Shardingin the Effect context (same aspeek/watch).Fix shard group derivation in
peek/flush/redeliverto useentity.getShardGroupinstead of actor name. The previous implementation computed wrong shard IDs (e.g."VectorUpdate:1"instead of"default:1"), which would have causedresetAddressto silently no-op.