Delayed Events

[ooraini]

I'm using the persistent events part of modulith which is simplifying a lot our code. But I'm facing a few use cases where I wish I could delay the event execution, for example, "send a reminder in 24 hours". While this can be done with a schedule and a DB table keep track of things. I feel like implementing it inside modulith will yield a far simpler implementation and a better usability.

It could be something like this:

interface DelayedEvent {
  Instant fireAt(); // null means immediately 
}

When receiving such an event, the modulith listener would just persist it in the persistent_events table with fireAt. At a later point some schedule will trigger the execution in the same way failed event listeners are run when restarting the application.