test_rpc.py 文件源码

def container(self, container_factory):

        class Service(object):
            name = "service"

            @rpc
            def nothing_expected(self):
                raise Backoff()

            @rpc(expected_exceptions=self.UserException)
            def something_expected(self):
                raise Backoff()

            @rpc(expected_exceptions=(self.UserException, Backoff))
            def backoff_expected(self):
                raise Backoff()

        config = {'AMQP_URI': 'memory://localhost'}
        container = container_factory(Service, config)
        return container