Lines Matching refs:this
9 * file that was distributed with this source code.
105 $this->queue = $queue;
106 $this->handlerFactory = $handlerFactory;
107 $this->options = array_merge($this->options, $options);
108 $this->authorizer = $authorizer ?? new ServerAuthorization(null, $this->options);
109 $this->protocolHandlerFactory = $protocolHandlerFactory ?? new ServerProtocolHandlerFactory(
113 $this->bindHandlerFactory = $bindHandlerFactory ?? new ServerBindHandlerFactory();
114 $this->responseFactory = $responseFactory ?? new ResponseFactory();
125 $this->defaultContext = $defaultContext;
128 while ($message = $this->queue->getMessage()) {
129 $this->dispatchRequest($message);
131 if (!$this->queue->isConnected()) {
138 $this->queue->sendMessage($this->responseFactory->getStandardResponse(
144 $this->logInfo(
148 $this->defaultContext
154 $this->sendNoticeOfDisconnect('The message encoding is malformed.');
155 $this->logError(
157 $this->defaultContext
160 $this->logError(
163 $this->defaultContext,
167 if ($this->queue->isConnected()) {
168 $this->sendNoticeOfDisconnect();
171 if ($this->queue->isConnected()) {
172 $this->queue->close();
184 $this->sendNoticeOfDisconnect(
188 $this->queue->close();
189 $this->logInfo(
206 if (!$this->isValidRequest($message)) {
210 $this->messageIds[] = $message->getMessageId();
213 if ($this->authorizer->isAuthenticationRequest($message->getRequest())) {
214 $this->authorizer->setToken($this->handleAuthRequest($message));
219 $handler = $this->protocolHandlerFactory->get(
225 if ($this->authorizer->isAuthenticated() || !$this->authorizer->isAuthenticationRequired($request)) {
228 $this->authorizer->getToken(),
229 $this->handlerFactory->makeRequestHandler(),
230 $this->queue,
231 $this->options
235 $this->queue->sendMessage($this->responseFactory->getStandardResponse(
252 $this->queue->sendMessage($this->responseFactory->getExtendedError(
259 if (in_array($message->getMessageId(), $this->messageIds, true)) {
260 $this->queue->sendMessage($this->responseFactory->getExtendedError(
279 if (!$this->authorizer->isAuthenticationTypeSupported($message->getRequest())) {
286 return $this->bindHandlerFactory->get($message->getRequest())->handleBind(
288 $this->handlerFactory->makeRequestHandler(),
289 $this->queue,
290 $this->options
302 $this->queue->sendMessage($this->responseFactory->getExtendedError(