commit 3070bf289f0673d0d30f8429d626ec381eda7ccd
author Christophe Bornet <cbornet@hotmail.com> Thu Jan 26 18:02:56 2023 +0100
committer GitHub <noreply@github.com> Thu Jan 26 18:02:56 2023 +0100
tree 135ab5bd72f6f34d6337cf9eb5ee0618ffaa0354
parent dfd82472e5e8b329c5864795ed52a9324662cf5c

Add correlation metadata to the message sent (#115)

* Add sendManyCorrelated to ReactiveMessageSender

Fixes #22

* Add correlation support for errors

* Test correlating errors

* sendOne shouldn't use correlation

* Add userContext to MessageSpec

* Update pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ReactiveMessageSendingException.java

* Fix test

Co-authored-by: Lari Hotari <lhotari@apache.org>
Co-authored-by: Lari Hotari <lhotari@users.noreply.github.com>