Skip to content

Commit

Permalink
Fix event topics
Browse files Browse the repository at this point in the history
Signed-off-by: Ian Costanzo <[email protected]>
  • Loading branch information
ianco committed Oct 28, 2021
1 parent 47d8a81 commit 819db0e
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 5 deletions.
6 changes: 3 additions & 3 deletions aries_cloudagent/core/util.py
Original file line number Diff line number Diff line change
Expand Up @@ -3,8 +3,8 @@
import re


CORE_EVENT_PREFIX = "acapy::CORE::"
STARTUP_EVENT_TOPIC = CORE_EVENT_PREFIX + "STARTUP"
CORE_EVENT_PREFIX = "acapy::core::"
STARTUP_EVENT_TOPIC = CORE_EVENT_PREFIX + "startup"
STARTUP_EVENT_PATTERN = re.compile(f"^{STARTUP_EVENT_TOPIC}?$")
SHUTDOWN_EVENT_TOPIC = CORE_EVENT_PREFIX + "SHUTDOWN"
SHUTDOWN_EVENT_TOPIC = CORE_EVENT_PREFIX + "shutdown"
SHUTDOWN_EVENT_PATTERN = re.compile(f"^{SHUTDOWN_EVENT_TOPIC}?$")
6 changes: 4 additions & 2 deletions aries_cloudagent/protocols/endorse_transaction/v1_0/routes.py
Original file line number Diff line number Diff line change
Expand Up @@ -705,12 +705,14 @@ def register_events(event_bus: EventBus):

async def on_startup_event(profile: Profile, event: Event):
"""Handle any events we need to support."""
print(">>> Received STARTUP event")
print(">>> TODO Received STARTUP event")
pass


async def on_shutdown_event(profile: Profile, event: Event):
"""Handle any events we need to support."""
print(">>> Received SHUTDOWN event")
print(">>> TODO Received SHUTDOWN event")
pass


async def register(app: web.Application):
Expand Down

0 comments on commit 819db0e

Please sign in to comment.