Hello,
I am using Akka projection (1.5.4) with JDBC (PostgreSQL). My source is DurableStateSourceProvider.changesByTag
. I get a DurableStateChange.UpdatedDurableState
envelope when I do an Effect.persist(state)
in my Durable state actor.
The problem is that I do not get any envelope when I do an Effect.delete()
, the handler is not called. The StatusObserver.beforeProcess()
is also not called for a deletion. On the other hand, it is called for a change.
This is very strange, because I expect to get an envelope with DurableStateChange.DeletedDurableState
inside when I do an Effect.delete()
.
Did I misunderstand something?
Thank you for your help.