apunkt/trustgraph
1
0
Fork 0
mirror of https://github.com/trustgraph-ai/trustgraph.git synced 2026-07-23 04:01:02 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions 2

Add unique ID to request/response subscriber names to keep them unique, so

Browse source 
that response subscribers see all responses.
This commit is contained in:
Cyber MacGeddon 2025-05-27 23:10:02 +01:00
parent c05ec25e39
commit 7315299192
1 changed files with 5 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

6
trustgraph-base/trustgraph/base/request_response_spec.py
View file

@ -127,8 +127,12 @@ class RequestResponseSpec(Spec):
rr = self.impl( rr = self.impl(
client = processor.pulsar_client, client = processor.pulsar_client,
# Make subscription names unique, so that all subscribers get
# to see all response messages
subscription = ( subscription = (
processor.id + "--" + flow.name + "--" + self.request_name processor.id + "--" + flow.name + "--" + self.request_name +
"--" + str(uuid.uuid4())
), ),
consumer_name = flow.id, consumer_name = flow.id,
request_topic = definition[self.request_name], request_topic = definition[self.request_name],