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)
def finish ( self ) : if self . _has_responded : raise NSQException ( 'already responded' ) self . _has_responded = True self . on_finish . send ( self )
Respond to nsqd that you’ve processed this message successfully
        (or would like to silently discard it).