Request Reply

[darren-bell-optiva]

Hi @kjeldpaw

First off, thanks for all of the great work that you are doing with this. It has progressed impressively since I was last able to look at the project.

I was hoping for some clarification/direction on achieving something like the capability of https://quarkus.io/guides/kafka#kafka-request-reply. I have had a look at https://github.com/quarkiverse/quarkus-reactive-messaging-nats-jetstream/blob/main/deployment/src/test/java/io/quarkiverse/reactive/messaging/nats/jetstream/test/RequestReplyResource.java and I'm not sure that it achieves the same thing. It seems more like a command/query type pattern. I could be wrong here so please correct me as my reactive programming is very much in the novice stage.

Essentially I was hoping to create some type of bridge between Rest and the messaging infrastructure while utilizing Jetstream. Do you have any thoughts on that or any direction to give? Also while looking at your implementation is seems that the return type on the publish method of the connection class expects the same type to be returned. Is there a specific reason for this or would it be possible for the requested and reply types to be different?

[kjeldpaw]

Hi @darren-bell-optiva I have been looking at the example I created. It looks strange ;) Therefore I'm working on a new solution

[darren-bell-optiva]

Hi @kjeldpaw Thanks for having another look at this. I appreciate your efforts. Let me know if there is anything that I can help with and I'll try my best to assist. Thanks