processing HTTPS requests and ZeroMQ messages in parallel inside Twisted

Question

I am trying to do two things in parallel:

• intercept HTTPS POST request and make Twisted hold the connection open indefinitely (return NOT_DONE_YET)
• listen to ZeroMQ queue (and close one of the pending connections as a result of a ZeroMQ message)

I know how to make each of these two things separately, but how can I do them in parallel? To be specific, how can I receive messages from ZeroMQ inside the Twisted framework, when I am already listening to TCP sockets?

Answer 1

You can get support for ZMQ here, in txZMQ.

It sounds like you already know how to deal with the HTTP request.

To do these things in parallel, just create your ZmqSubConnection and your twisted.web.server.Site, with references to each other as necessary for your application. No special set-up is required.

Just make sure you only create and run one reactor. Other people with similar questions sometimes don't understand that reactor.run() means "run the event loop for the whole process", and not "run this one thing I set up".