zengine.tornado_server package

Submodules

zengine.tornado_server.get_logger module

zengine.tornado_server.get_logger.get_logger(settings)

zengine.tornado_server.ws_to_queue module

class zengine.tornado_server.ws_to_queue.QueueManager(io_loop=None)

Bases: object

Async RabbitMQ & Tornado websocket connector

INPUT_QUEUE_NAME = 'in_queue'

connect()

Creates connection to RabbitMQ server

create_out_channel(sess_id)

inform_disconnection(sess_id)

on_channel_open(channel)

Input channel creation callback Queue declaration done here

Parameters:channel – input channel

on_connected(connection)

AMQP connection callback. Creates input channel.

Parameters:connection – AMQP connection

on_input_queue_declare(queue)

Input queue declaration callback. Input Queue/Exchange binding done here

Parameters:queue – input queue

on_message(channel, method, header, body)

redirect_incoming_message(sess_id, message, request)

register_websocket(sess_id, ws)

Parameters:

• sess_id –
• ws –

unregister_websocket(sess_id)

class zengine.tornado_server.ws_to_queue.settings

Bases: object

ALLOWED_ORIGINS = 'http://127.0.0.1'

DEBUG = False

LOG_FILE = 'tornado.log'

LOG_HANDLER = 'file'

LOG_LEVEL = 'DEBUG'

MQ_HOST = 'localhost'

MQ_PASS = 'guest'

MQ_PORT = 5672

MQ_USER = 'guest'

MQ_VHOST = '/'

zengine.tornado_server.server module

tornado websocket proxy for WF worker daemons

class zengine.tornado_server.server.HttpHandler(application, request, **kwargs)

Bases: tornado.web.RequestHandler

login handler class

get(*args, **kwargs)

only used to display login form

Parameters:view_name – should be “login”

post(*args, **kwargs)

login handler

write_message(output)

class zengine.tornado_server.server.SocketHandler(application, request, **kwargs)

Bases: tornado.websocket.WebSocketHandler

websocket handler

check_origin(origin)

Prevents CORS attacks.

Parameters:origin – HTTP “Origin” header. URL of initiator of the request. Returns:True if origin is legit, otherwise False

on_close()

remove connection from pool on connection close.

on_message(message)

called on new websocket message,

open()

Called on new websocket connection.

zengine.tornado_server.server.runserver(host=None, port=None)

Run Tornado server

Module contents