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 [email protected].
To post to this group, send email to [email protected].
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.
