Channel Layer GROUP issue or mb ?

[Guidoow]

Hi and thanks for reading!

I'm experimenting with in memory channel layers, because I can't use Redis with Windows yet, and I ran into a problem when I tried to consume a message from groups.
As I understood from reading the docs, the group_send method adds sent messages to a queue and, if there is a specified "type" key in the sent dictionary, executes a consumer function (named in the key value) that is in the specified group and has a persistent connection.

I'm new to development, anyway I got around to exploring the code, and I can tell that all the messages I send are perfectly queued, but there is no function execution.

Maybe there isn't only a persistent connection required from the user who is in the group, but too a message sent to the receive() consumer method for then manually check for queued messages, read and send them? or maybe I am doing something wrong?

Again, thanks for reading. <3

[carltongibson]

Hi @Guidoow — can you show how you're invoking the group_send()? i.e. the consumer.

A minimal reproduce would be good to be able to help you

[Guidoow]

group_add in consumer connect method:
async_to_sync(self.channel_layer.group_add)('chat',self.channel_name)

group_send when a user sent a message:
async_to_sync(self.channel_layer.group_send)('chat',message)
how i said i check it was stored by a terminal print:
<Queue maxsize=0 _queue=[(1665792743.370699, {'userFrom': 'guido', 'fecha': '2022-10-14 21:11:23.293981', 'message': 'gh test', 'image': ''})] tasks=1>

I also tried creating a single group for each consumer and send messages to himself, with one and two consumers and the same time and no one method works :(

[carltongibson]

Hi @Guidoow -- can I ask you to put together a minimal reproduce please? I can't see the issue from just these fragments.

[Guidoow]

Hi, i have some things mixed in my code and maybe is it not really clear, but i hope this helps!
main methods receive and connect.

Auth method and setting channel names.

sending messages:

function that should execute automatically?

console log:

As you can see in the "group_send" image, I was trying to send to my same channel and then receive the messages with a function that executes: 'async_to_sync(self.channel_layer.receive)(self.user)' and works! but when I tried to receive and there is no message in the queue, the server stops completely and crashes.

if there is any issue, please consider contacting me via gmail !

[Guidoow]

@carltongibson I had to perform a windows 0 boot because it gave me some errors on actualization, fortunately I can use Redis correctly, but I still can't fix the channels error :/