Skip to content
Snippets Groups Projects
Commit 0b0f81e1 authored by Jorrit Schaap's avatar Jorrit Schaap
Browse files

SW-657: added RPC-Service name to the temporary queue, use same broker as sender for tmpqueue

parent 5bb6aa54
Branches
Tags
No related merge requests found
......@@ -155,7 +155,8 @@ class RPC():
self.request_sender.subject,
timeout)
with TemporaryQueue(self.broker) as tmp_queue:
tmp_queue_postfix = self.request_sender.address
with TemporaryQueue(name=tmp_queue_postfix, broker=self.broker) as tmp_queue:
with tmp_queue.create_frombus(connection_log_level=logging.DEBUG) as reply_receiver:
request_msg = RequestMessage(content=Content, reply_to=reply_receiver.address,
has_args=HasArgs, has_kwargs=HasKwArgs)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment