Hi @Tamimi
Thanks for the answer. I looked at the snipped for requestor but still don’t see how to set replyTo topic. It seems the example sets only request_destination >
from solace.messaging.publisher.request_reply_message_publisher import RequestReplyMessagePublisher
Create a direct message requestor and register the error handler
direct_requestor: RequestReplyMessagePublisher = messaging_service.request_reply()
.create_request_reply_message_publisher_builder()
.build()
direct_requestor.start()
outbound_msg = messaging_service.message_builder().build(f’\n{insert_your_message_here}')
response = direct_requestor_blocking.publish_await_response(request_message=outbound_msg,
request_destination=destination_topic,
reply_timeout=10000)
Unfortunately our system expects that replies are send to {replier-service-name}/to/{requestor-service-name}/{subject} so we can easily filter all replies by source or destination service or by subject