use nameko

namekoservice.py

import os
from nameko.rpc import rpc
from nameko.cli import run


rabbit_config = {
    'AMQP_URI': os.environ['AMQP_URI'],
    'rpc_exchange': 'smstaskrpc',
    'max_workers': 20,
    'parent_calls_tracked': 10,
}


class XXService:
    name = "xxservice"

    @rpc
    def send(self, sendinfo):
        pass
        return


if __name__ == '__main__':
    import sys
    services = [XXService]
    run.run(services, rabbit_config)