-
Notifications
You must be signed in to change notification settings - Fork 3.6k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Preparations for external transport of replicated events #31771
Preparations for external transport of replicated events #31771
Conversation
johanandren
commented
Nov 29, 2022
- Ack protocol for the events being consumed
- A factory method to create replicated es entities without journal trailing through persistence query
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
great to see that it fits in with the existing mechanism
akka-persistence-typed/src/main/scala/akka/persistence/typed/internal/Running.scala
Outdated
Show resolved
Hide resolved
akka-persistence-typed/src/main/scala/akka/persistence/typed/internal/Running.scala
Outdated
Show resolved
Hide resolved
a5c30e1
to
88ff9e7
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM. 👍🏼 great that the existing mechanism can be used.
...ersistence-typed/src/main/scala/akka/persistence/typed/javadsl/ReplicatedEventSourcing.scala
Outdated
Show resolved
Hide resolved
...rsistence-typed/src/main/scala/akka/persistence/typed/scaladsl/ReplicatedEventSourcing.scala
Outdated
Show resolved
Hide resolved
Co-authored-by: Peter Vlugter <pvlugter@users.noreply.github.com>
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM, after something minor
setup.internalLogger.warn("Received published event for [{}] but with no replicated metadata, dropping") | ||
setup.internalLogger.warn( | ||
"Received published event for [{}] but with no replicated metadata, dropping", | ||
event.persistenceId) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
👍