test_rpc.py 文件源码

def test_non_backoff_exception(
        self, container_factory, rabbit_config, rpc_proxy
    ):
        """ Non-backoff exceptions are handled normally
        """
        class Boom(Exception):
            pass

        class Service(object):
            name = "service"

            @rpc
            def method(self):
                raise Boom()

        container = container_factory(Service, rabbit_config)
        container.start()

        with pytest.raises(RemoteError) as exc_info:
            rpc_proxy.service.method()
        assert exc_info.value.exc_type == "Boom"