def check_logs():
    msgs = [e['log_format'] for e in logObserver]
    self.assertIn('connected to publisher', msgs)
    self.assertIn('could not connect to distributed web service: {msg}', msgs)
    self.assertIn(req[0], msgs)
    globalLogPublisher.removeObserver(logObserver)
def check_logs():
    msgs = [e['log_format'] for e in logObserver]
    self.assertIn('connected to publisher', msgs)
    self.assertIn('could not connect to distributed web service: {msg}', msgs)
    self.assertIn(req[0], msgs)
    globalLogPublisher.removeObserver(logObserver)