Yeah, I see.
Lagom has this built-in.
If you can’t move to Lagom, then maybe you should try get some inspirations from there.
Have a look at JpaSession and the read-side processors for JPA.
Note that Lagom goes much further than that. It also helps you to shard your journal and have different consumers polling data from it distributed in your cluster.