def METHOD_NAME(self):
    """Stop the PubSub system."""
    assert(self.__running)
    self.__broker_channel.put(None)
    self.__publish_channel.close()
    self.__broker_channel.close()
    self.__broker_process.join()
    self.__running = False