code: def finish(self, message_id):
          
          self.send(nsq.finish(message_id))
          self.finish_inflight()
          self.on_finish.send(self, message_id=message_id)
docs: Finish a message (indicate successful processing).