INNER CODE UNIT · Python

register_message_writers

yann-shi/Young · server.py:24

def register_message_writers():
    '''为nsq消息系统建立生产者'''

    WriterManager.writer = nsq.Writer(['127.0.0.1:4150'])


def register_message_readers():
    '''为nsq消息系统建立消费者'''

    handlers = {
        MessageTopic.CHAT_MESSAGE_NEW:
            chat_message_handler,

        MessageTopic.SEND_ACTIVATION_EMAIL:
            send_activation_email_handler,

        MessageTopic.SEND_RESET_PASSWORD_EMAIL:
            send_reset_password_email_handler,

View source record →