Ok, but that doesnt'solve the problem with handling the events in the right
process.
Anyway, I think I figured it out. It seems there is nothing magical to a
'protocol handler' after all, so I can just create a thread with its event
loop and run the MQTT listener in there. No other processes required, and I
don't even need to use a channel layer as long as I can live without the
group facilities.
Runs fine in development mode, let's hope it does not blow up with an
external ASGI server.
andrea
On Monday, May 6, 2019 at 6:26:52 AM UTC+2, Fly Style wrote:
>
> for example:
>
> from asgiref.sync import async_to_sync as a2s
> from channels.layers import get_channel_layer
> from channels_mqtt import settings
>
>
> event = {"type": settings.MQTT_PUBLISH, "text": {"topic": topic, "payload"
> : payload, "qos": qos, "retain": retain}}
> a2s(channel_layer.send)(channel, event)
>
>
--
You received this message because you are subscribed to the Google Groups
"Django users" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to django-users+unsubscr...@googlegroups.com.
To post to this group, send email to django-users@googlegroups.com.
Visit this group at https://groups.google.com/group/django-users.
To view this discussion on the web visit
https://groups.google.com/d/msgid/django-users/ba3fe782-9efe-4bc9-a5af-d9c10fc9f2f2%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.
