protected function doSendRequest(Request $request): Response
    {
        if (!$this->shouldUseGearman()) {
            return $this->locator->getRequestBus()->receiveRequest($request);
        }

        $envelope = new TransportEnvelope($request, 'php');
        $channel = $this->router->forRequest($request);

        try {
            $client = $this->getClient();
            $result = @$client->doNormal($channel, $envelope->toString(), (string)$request->get('request_id'));
            $this->validateReturnCode($client, $channel);
            return TransportEnvelope::fromString($result)->getMessage();
        } catch (\GearmanException $ge) {
            if (isset(self::$reconnectCodes[$ge->getCode()])) {
                $this->destroyClient();
                return $this->locator->getRequestBus()->receiveRequest($request);
            }

            throw $ge;
        } catch (\Throwable $e) {
            throw $e;
        }
    }
protected function doSendRequest(Request $request): Response
    {
        if (!$this->shouldUseGearman()) {
            return $this->locator->getRequestBus()->receiveRequest($request);
        }

        $envelope = new TransportEnvelope($request, 'php');
        $channel = $this->router->forRequest($request);

        try {
            $client = $this->getClient();
            $result = @$client->doNormal($channel, $envelope->toString(), (string)$request->get('request_id'));
            $this->validateReturnCode($client, $channel);
            return TransportEnvelope::fromString($result)->getMessage();
        } catch (\GearmanException $ge) {
            if (isset(self::$reconnectCodes[$ge->getCode()])) {
                $this->destroyClient();
                return $this->locator->getRequestBus()->receiveRequest($request);
            }

            throw $ge;
        } catch (\Throwable $e) {
            throw $e;
        }
    }
protected function doSendRequest ( Request $ request ) : Response { if ( ! $ this -> shouldUseGearman ( ) ) { return $ this -> locator -> getRequestBus ( ) -> receiveRequest ( $ request ) ; } $ envelope = new TransportEnvelope ( $ request , 'php' ) ; $ channel = $ this -> router -> forRequest ( $ request ) ; try { $ client = $ this -> getClient ( ) ; $ result = @ $ client -> doNormal ( $ channel , $ envelope -> toString ( ) , ( string ) $ request -> get ( 'request_id' ) ) ; $ this -> validateReturnCode ( $ client , $ channel ) ; return TransportEnvelope :: fromString ( $ result ) -> getMessage ( ) ; } catch ( \ GearmanException $ ge ) { if ( isset ( self :: $ reconnectCodes [ $ ge -> getCode ( ) ] ) ) { $ this -> destroyClient ( ) ; return $ this -> locator -> getRequestBus ( ) -> receiveRequest ( $ request ) ; } throw $ ge ; } catch ( \ Throwable $ e ) { throw $ e ; } }
Processes the request in memory synchronously.

@param Request $request

@return Response
@throws \Exception
Processes the request in memory synchronously .