Skip to content

Commit 5f7330a

Browse files
committed
fix: add event namespace to base records to allow plugins to override
Signed-off-by: Daniel Bluhm <[email protected]>
1 parent 7647590 commit 5f7330a

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

aries_cloudagent/messaging/models/base_record.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -70,6 +70,7 @@ class Meta:
7070
RECORD_ID_NAME = "id"
7171
RECORD_TYPE = None
7272
RECORD_TOPIC: Optional[str] = None
73+
EVENT_NAMESPACE: str = "acapy::record"
7374
LOG_STATE_FLAG = None
7475
TAG_NAMES = {"state"}
7576

@@ -383,9 +384,9 @@ async def emit_event(self, session: ProfileSession, payload: Any = None):
383384
return
384385

385386
if self.state:
386-
topic = f"acapy::record::{self.RECORD_TOPIC}::{self.state}"
387+
topic = f"{self.EVENT_NAMESPACE}::{self.RECORD_TOPIC}::{self.state}"
387388
else:
388-
topic = f"acapy::record::{self.RECORD_TOPIC}"
389+
topic = f"{self.EVENT_NAMESPACE}::{self.RECORD_TOPIC}"
389390

390391
if not payload:
391392
payload = self.serialize()

0 commit comments

Comments
 (0)