Lines Matching refs:queue
59 protected $queue;
97 ServerQueue $queue,
105 $this->queue = $queue;
128 while ($message = $this->queue->getMessage()) {
131 if (!$this->queue->isConnected()) {
138 $this->queue->sendMessage($this->responseFactory->getStandardResponse(
167 if ($this->queue->isConnected()) {
171 if ($this->queue->isConnected()) {
172 $this->queue->close();
188 $this->queue->close();
196 * Routes requests from the message queue based off the current authorization state and what protocol handler the
230 $this->queue,
235 $this->queue->sendMessage($this->responseFactory->getStandardResponse(
252 $this->queue->sendMessage($this->responseFactory->getExtendedError(
260 $this->queue->sendMessage($this->responseFactory->getExtendedError(
289 $this->queue,
302 $this->queue->sendMessage($this->responseFactory->getExtendedError(