-
Notifications
You must be signed in to change notification settings - Fork 67
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
Implement keyed messages #44
Conversation
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.
That was fast @alpreu ! Thanks, looks great. I have a few minor comments/suggestions to follow up on. Additionally,
- Please add yourself as
@author
on all modified files. - Do you mind adding some tests cases to the existing PulsarTemplateTests?
Thanks again for the contribution!
spring-pulsar/src/main/java/org/springframework/pulsar/core/PulsarOperations.java
Outdated
Show resolved
Hide resolved
spring-pulsar/src/main/java/org/springframework/pulsar/core/TypedMessageBuilderCustomizer.java
Outdated
Show resolved
Hide resolved
spring-pulsar/src/main/java/org/springframework/pulsar/core/TypedMessageBuilderCustomizer.java
Outdated
Show resolved
Hide resolved
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.
Looks great @alpreu . Thanks for the updates and adding the tests. The only comment I have is around type info to the customizer. Once we resolve that we can remove the draft status and I will get it merged in.
Thank you for the feedback, I added the type to the message builder and updated the docs to reflect the changes. If it looks good to you I'll squash and rebase so you can merge :) |
Looks good @alpreu . I went ahead and squash/rebase/merge. Thanks again for contribution! |
This PR should implement keyed messaging on the PulsarTemplate (#26).
A detailed description follows.