code: def run(self):
          
          self.started_queue.put('STARTED')
  
          while True:
              event = self.publisher_queue.get()
              if event == POISON_PILL:
                  return
              else:
                  self.dispatch(event)
docs: Start the exchange