public function onMessage(Connection $conn, Message $msg)
    {
        $this->totalRdyCount--;
        $this->stats["messagesReceived"]++;

        yield $this->handleMessage($msg);
        // 收到消息后更新rdy
        // 李文告知不需要每次收到消息就调整RDY
        // $this->maybeUpdateRDY($conn);
    }
public function onMessage(Connection $conn, Message $msg)
    {
        $this->totalRdyCount--;
        $this->stats["messagesReceived"]++;

        yield $this->handleMessage($msg);
        // 收到消息后更新rdy
        // 李文告知不需要每次收到消息就调整RDY
        // $this->maybeUpdateRDY($conn);
    }
public function onMessage ( Connection $ conn , Message $ msg ) { $ this -> totalRdyCount -- ; $ this -> stats [ "messagesReceived" ] ++ ; yield $ this -> handleMessage ( $ msg ) ; // 收到消息后更新rdy // 李文告知不需要每次收到消息就调整RDY // $this->maybeUpdateRDY($conn); }
OnMessage is called when the connection
receives a FrameTypeMessage from nsqd
@param Connection $conn
@param Message $msg
@return void
OnMessage is called when the connection receives a FrameTypeMessage from nsqd