nsq源码(6) nsqd 通知消息完成

通知nsqd执行完成操作

• 在客户端接收到消息并处理完成之后，按照协议会向nsqd 发送一个 "FIN" 命令通知nsqd，移除队列信息

func (p *protocolV2) FIN(client *clientV2, params [][]byte) ([]byte, error) {
    id, err := getMessageID(params[1])

    err = client.Channel.FinishMessage(client.ID, *id)

    client.FinishedMessage()
    return nil, nil
}

func (c *Channel) FinishMessage(clientID int64, id MessageID) error {
    // 移除缓存inFlightMessages
    msg, err := c.popInFlightMessage(clientID, id)
    
    // 移除超时队列inFlightPQ
    c.removeFromInFlightPQ(msg)
    
    return nil
}