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