Skip to content

Commit

Permalink
Update topic config + comment.
Browse files Browse the repository at this point in the history
  • Loading branch information
seeker25 committed May 2, 2024
1 parent 6d71cd5 commit ab97e24
Show file tree
Hide file tree
Showing 4 changed files with 4 additions and 6 deletions.
2 changes: 1 addition & 1 deletion auth-api/src/auth_api/config.py
Original file line number Diff line number Diff line change
Expand Up @@ -138,7 +138,7 @@ class _Config: # pylint: disable=too-few-public-methods
# PUB/SUB
GCP_AUTH_KEY = os.getenv('GCP_AUTH_KEY', None)
ACCOUNT_MAILER_TOPIC = os.getenv('ACCOUNT_MAILER_TOPIC', 'account-mailer-dev')
ACTIVITY_LISTENER_TOPIC = os.getenv('ACTIVITY_LISTENER_TOPIC', 'activity-listener-dev')
AUTH_EVENT_TOPIC = os.getenv('AUTH_EVENT_TOPIC', 'auth-event-dev')

# Minio configuration values
MINIO_ENDPOINT = os.getenv('MINIO_ENDPOINT')
Expand Down
2 changes: 1 addition & 1 deletion auth-api/src/auth_api/services/activity_log_publisher.py
Original file line number Diff line number Diff line change
Expand Up @@ -60,7 +60,7 @@ def publish_activity(activity: Activity): # pylint:disable=unused-argument
type=QueueMessageTypes.ACTIVITY_LOG.value,
data=data
)
queue.publish(CONFIG.ACTIVITY_LISTENER_TOPIC, GcpQueue.to_queue_message(cloud_event))
queue.publish(CONFIG.AUTH_EVENT_TOPIC, GcpQueue.to_queue_message(cloud_event))
except Exception as err: # noqa: B902 # pylint: disable=broad-except
capture_message('Activity Queue Publish Event Error:' + str(err), level='error')
current_app.logger.error('Activity Queue Publish Event Error:', exc_info=True)
2 changes: 1 addition & 1 deletion queue_services/account-mailer/src/account_mailer/config.py
Original file line number Diff line number Diff line change
Expand Up @@ -96,7 +96,7 @@ class _Config(): # pylint: disable=too-few-public-methods
REPORT_API_BASE_URL = f'{os.getenv("REPORT_API_URL")}/reports'

# PUB/SUB
ACCOUNT_MAILER_TOPIC = os.getenv('ACCOUNT_MAILER_TOPIC', 'account-mailer-dev')
# SUBSCRIBES TO THIS TOPIC: account-mailer-dev
AUTH_SUB_AUDIENCE = os.getenv('AUTH_SUB_AUDIENCE')

# Minio configuration values
Expand Down
4 changes: 1 addition & 3 deletions queue_services/auth-queue/src/auth_queue/config.py
Original file line number Diff line number Diff line change
Expand Up @@ -78,9 +78,7 @@ class _Config: # pylint: disable=too-few-public-methods
AUTH_SUB_AUDIENCE = os.getenv('AUTH_SUB_AUDIENCE')

ACCOUNT_MAILER_TOPIC = os.getenv('ACCOUNT_MAILER_TOPIC', 'account-mailer-dev')
ACTIVITY_LISTENER_TOPIC = os.getenv('ACTIVITY_LISTENER_TOPIC', 'activity-listener-dev')
EVENT_LISTENER_TOPIC = os.getenv('EVENT_LISTENER_TOPIC', 'auth-event-dev')
NAMES_NR_STATE_TOPIC = os.getenv('NAMES_NR_STATE_TOPIC', 'namex-nr-state-dev')
# SUBSCRIBES TO THESE TOPICS: auth-event-dev and namex-nr-state-dev

PAY_API_URL = os.getenv('PAY_API_URL') + os.getenv('PAY_API_VERSION')

Expand Down

0 comments on commit ab97e24

Please sign in to comment.