channels_rabbitmq
channels_rabbitmq copied to clipboard
`await get_channel_layer().receive()` doesn't connect
If you call await get_channel_layer().receive()
on a newly-instantiated channel layer, it won't connect to RabbitMQ. The connect only happens on send()
or group_add()
.
To fix, make receive()
await the connection. (Ignore failed connections?)