hsyclibs/tests/test_mqman.py

# coding: utf-8
from hsyclibs import mqman


def test_mqman_client():
    client = mqman.RpcClient('tieta')
    ret = client.call(b'hi')
    print(ret)


def test_mqman_server():
    mqman.RpcServer(lambda x: b'hi ' + x, 'tieta').start_consuming()