apunkt/trustgraph
1
0
Fork 0
mirror of https://github.com/trustgraph-ai/trustgraph.git synced 2026-04-25 08:26:21 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Add unique ID to request/response subscriber names so subscribes see all responses (#399)

Browse source
This commit is contained in:
cybermaggedon 2025-05-27 23:11:55 +01:00 • committed by GitHub
parent c05ec25e39
commit 4ffb677488
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
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(
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],