stash
This commit is contained in:
parent
fe93366bd2
commit
0e84994b62
1 changed files with 1 additions and 0 deletions
|
@ -13,6 +13,7 @@ class NotificationDispatcher:
|
||||||
async def run_forever(self):
|
async def run_forever(self):
|
||||||
|
|
||||||
# Infinite loop to continuously listen for messages
|
# Infinite loop to continuously listen for messages
|
||||||
|
print("Listening for messages...")
|
||||||
while True:
|
while True:
|
||||||
# Blocking receive to get the message from the channel layer
|
# Blocking receive to get the message from the channel layer
|
||||||
message = await self.channel_layer.receive('general')
|
message = await self.channel_layer.receive('general')
|
||||||
|
|
Loading…
Reference in a new issue