stash
This commit is contained in:
parent
fbc21b5016
commit
fe3c9be4ab
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