docs: def finish(self):
          """
          Respond to nsqd that you’ve processed this message successfully
          (or would like to silently discard it).
          """
          if self._has_responded:
              raise NSQException('already responded')
          self._has_responded = True
          self.on_finish.send(self)