def start_riemann_server(self): factory = FakeRiemannServerFactory() self.addCleanup(factory.stop_listening) return factory.start_listening(TCP4ServerEndpoint(reactor, 0))