stash
This commit is contained in:
parent
22f164ae7b
commit
163de03d56
2 changed files with 2 additions and 2 deletions
|
@ -15,7 +15,7 @@ class NotificationDispatcher:
|
|||
# Infinite loop to continuously listen for messages
|
||||
while True:
|
||||
# Blocking receive to get the message from the channel layer
|
||||
message = await self.channel_layer.receive()
|
||||
message = await self.channel_layer.receive('user_notification')
|
||||
|
||||
if message:
|
||||
# Process the received message
|
||||
|
|
|
@ -289,7 +289,7 @@ class LMTPHandler:
|
|||
log.info(f"Sent message to frontend")
|
||||
if notifcation:
|
||||
await channel_layer.group_send(
|
||||
'general', {"type": "generic.event", "name": "push_notification", "event_id": systemevent.id,
|
||||
'general', {"type": "generic.event", "name": "user_notification", "event_id": systemevent.id,
|
||||
"message": notifcation})
|
||||
if new and reply:
|
||||
log.info('Sending message to %s' % reply['To'])
|
||||
|
|
Loading…
Reference in a new issue