Lines Matching refs:queue
82 $queue = $context->getQueue();
84 $queue->sendMessage($message);
87 $response = $queue->getMessage($message->getMessageId());
98 $response = $this->processSaslChallenge($request, $queue, $saslResponse, $mech);
144 * @param ClientQueue $queue
157 ClientQueue $queue,
167 $response = $this->sendRequestGetResponse($saslBind, $queue);
182 $queue->setMessageWrapper(new SaslMessageWrapper($mech->securityLayer(), $context));
190 * @param ClientQueue $queue
197 protected function sendRequestGetResponse(SaslBindRequest $request, ClientQueue $queue): LdapMessageResponse
199 $messageTo = $this->makeRequest($queue, $request, $this->controls);
200 $queue->sendMessage($messageTo);
203 $messageFrom = $queue->getMessage($messageTo->getMessageId());