public function getMessage()

in src/Apache/Ignite/Internal/Binary/Request.php [52:72]


    public function getMessage(): MessageBuffer
    {
        $message = new MessageBuffer();
        // Skip message length
        $messageStartPos = BinaryUtils::getSize(ObjectType::INTEGER);
        $message->setPosition($messageStartPos);
        if ($this->opCode >= 0) {
            // Op code
            $message->writeShort($this->opCode);
            // Request id
            $message->writeLong($this->id);
        }
        if ($this->payloadWriter !== null) {
            // Payload
            call_user_func($this->payloadWriter, $message);
        }
        // Message length
        $message->setPosition(0);
        $message->writeInteger($message->getLength() - $messageStartPos);
        return $message;
    }