Cmobi\RabbitmqBundle\Rpc\Handler::handle()

Complexity

Conditions	3
Paths	3

Size

Total Lines	22
Code Lines	17

Duplication

Lines	0
Ratio	0 %

Importance

Changes	5
Bugs	1	Features	2

<?php
    public function handle(RpcRequestCollectionInterface $requests, RpcResponseCollectionInterface $responses)
    {
        foreach ($requests as $request) {

The expression $requests of type object<Cmobi\RabbitmqBundle\Rpc\Request\RpcRequestCollectionInterface> is not traversable.

            $controller = $this->getResolver()->getController($request);
            $arguments = $this->getResolver()->getArguments($request, $controller);
            $response = call_user_func_array($controller, $arguments);

            if (!is_array($response)) {
                $previous = new InvalidBodyAMQPMessageException('Invalid Body: Content should be array.');
                $exception = new JsonRpcInternalErrorException($previous);
                $error = new JsonRpcResponse([], $exception);
                $error->setId($request->id);
                $error->setMethod($request->method);
                $responses->add($error);
            } else {
                $response = new JsonRpcResponse($response);
                $response->setId($request->id);
                $response->setMethod($request->method);
                $responses->add($response);
            }
        }
    }

}