code: def close(self):
          
          for channel in self._listening_to:
              self.toredis.unsubscribe(channel)
          self.toredis.unsubscribe(self.group_pubsub)
docs: Unsubscribe the group and all jobs being listened too