zengine.tornado_server package¶
Submodules¶
zengine.tornado_server.get_logger module¶
zengine.tornado_server.ws_to_queue module¶
-
class
zengine.tornado_server.ws_to_queue.
QueueManager
(io_loop=None)[source]¶ Bases:
object
Async RabbitMQ & Tornado websocket connector
-
INPUT_QUEUE_NAME
= 'in_queue'¶
-
on_channel_open
(channel)[source]¶ Input channel creation callback Queue declaration done here
Parameters: channel – input channel
-
on_connected
(connection)[source]¶ AMQP connection callback. Creates input channel.
Parameters: connection – AMQP connection
-
zengine.tornado_server.server module¶
tornado websocket proxy for WF worker daemons
-
class
zengine.tornado_server.server.
HttpHandler
(application, request, **kwargs)[source]¶ Bases:
tornado.web.RequestHandler
login handler class
-
class
zengine.tornado_server.server.
SocketHandler
(application, request, **kwargs)[source]¶ Bases:
tornado.websocket.WebSocketHandler
websocket handler