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
评论列表
文章目录