Lines Matching defs:message
71 $message = $this->consume();
72 if ($message !== null) {
73 yield $this->constructMessage($message, $id);
127 $message = null;
130 $message = $this->decode($this->toConsume);
131 $lastPos = (int)$message->getLastPosition();
147 if ($message === null) {
151 return $message;
184 * Retrieve the message object from the message. Allow for special construction / validation if needed.
186 * @param Message $message
190 protected function constructMessage(Message $message, ?int $id = null)
192 return $message->getMessage();