Channel_layer.send не вызывает обработчик

У меня есть этот сигнал для отправки события при создании нового сообщения

from django.db.models.signals import post_save
from channels.layers import get_channel_layer
from asgiref.sync import async_to_sync
from django.dispatch import receiver

from .serializers import MessageSerializer
from base.models import Message

@receiver(post_save, sender=Message)
def new_message(sender, instance, created, **kwargs):
    channel_layer = get_channel_layer()

    if created:
        chat_group = instance.channel.chat_group
        for member in chat_group.members:
            async_to_sync(channel_layer.send)(
                f"User-{member.user.id}",
                {
                    "type": "chat_message_create",
                    "payload": MessageSerializer(instance).data,
                },
            )

это consumers.py

import json
from channels.generic.websocket import WebsocketConsumer

from api.serializers import UserSerializer


class ChatConsumer(WebsocketConsumer):
    def connect(self):
        user = self.scope["user"]
        self.channel_name = f"User-{user.id}"
        self.send(text_data=json.dumps(UserSerializer(user).data))

    def disconnect(self, close_code):
        pass

    def chat_message_create(self, event):
        print("Created")
        self.send(text_data=json.dumps(event["payload"]))

Когда я создаю новое сообщение в панели администратора, вызывается сигнал, но он не передается через websocket, и любые отладочные отпечатки в ChatConsumer.chat_message_create даже не выводятся.

Заранее спасибо

Вернуться на верх