From 4ffb677488c15513d212a7830560e771d0812b3a Mon Sep 17 00:00:00 2001 From: cybermaggedon Date: Tue, 27 May 2025 23:11:55 +0100 Subject: [PATCH] Add unique ID to request/response subscriber names so subscribes see all responses (#399) --- trustgraph-base/trustgraph/base/request_response_spec.py | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/trustgraph-base/trustgraph/base/request_response_spec.py b/trustgraph-base/trustgraph/base/request_response_spec.py index 7b8b1be8..e4763a13 100644 --- a/trustgraph-base/trustgraph/base/request_response_spec.py +++ b/trustgraph-base/trustgraph/base/request_response_spec.py @@ -127,8 +127,12 @@ class RequestResponseSpec(Spec): rr = self.impl( client = processor.pulsar_client, + + # Make subscription names unique, so that all subscribers get + # to see all response messages subscription = ( - processor.id + "--" + flow.name + "--" + self.request_name + processor.id + "--" + flow.name + "--" + self.request_name + + "--" + str(uuid.uuid4()) ), consumer_name = flow.id, request_topic = definition[self.request_name],