Lines Matching defs:message

124         $message = null;
128 while ($message = $this->queue->getMessage()) {
129 $this->dispatchRequest($message);
137 # specific error code and message associated with the exception.
139 $message,
147 ['message' => $e->getMessage()],
154 $this->sendNoticeOfDisconnect('The message encoding is malformed.');
196 * Routes requests from the message queue based off the current authorization state and what protocol handler the
204 protected function dispatchRequest(LdapMessageRequest $message): void
206 if (!$this->isValidRequest($message)) {
210 $this->messageIds[] = $message->getMessageId();
213 if ($this->authorizer->isAuthenticationRequest($message->getRequest())) {
214 $this->authorizer->setToken($this->handleAuthRequest($message));
218 $request = $message->getRequest();
221 $message->controls()
227 $message,
236 $message,
244 * Checks that the message ID is valid. It cannot be zero or a message ID that was already used.
249 protected function isValidRequest(LdapMessageRequest $message): bool
251 if ($message->getMessageId() === 0) {
253 'The message ID 0 cannot be used in a client request.',
259 if (in_array($message->getMessageId(), $this->messageIds, true)) {
261 sprintf('The message ID %s is not valid.', $message->getMessageId()),
277 protected function handleAuthRequest(LdapMessageRequest $message): TokenInterface
279 if (!$this->authorizer->isAuthenticationTypeSupported($message->getRequest())) {
286 return $this->bindHandlerFactory->get($message->getRequest())->handleBind(
287 $message,
295 * @param string $message
299 string $message = '',
303 $message,