1
Try this:
from channels import Group
from .models import Message
from channels import Channel
def msg_consumer(message):
text = message.content.get('text')
Message.objects.create(
message=text,
)
Group("chat").send({'text': text})
def ws_connect(message):
message.reply_channel.send({"accept": True})
Group("chat").add(message.reply_channel)
def ws_receive(message):
Channel("chat").send({
"text": message.content['text'],
})
def ws_disconnect(message):
Group("chat").discard(message.reply_channel)
Updated solution
1
def msg_consumer(message):
# Save to model
Message.objects.create(
message = message.content['text']
)
# Broadcast to listening sockets
Group("chat").send({
"text": message.content['text'],
})
you try, If this does not work, I do not know, sorry
Source:stackexchange.com