@@ -14,7 +14,7 @@ |
||
14 | 14 | { |
15 | 15 | $collection = new MethodCollection(); |
16 | 16 | $root = $this->getContainer()->getParameter('kernel.root_dir'); |
17 | - $resource = $root . DIRECTORY_SEPARATOR . 'app' . DIRECTORY_SEPARATOR . 'config' . DIRECTORY_SEPARATOR . 'rpc_routing.yml'; |
|
17 | + $resource = $root.DIRECTORY_SEPARATOR.'app'.DIRECTORY_SEPARATOR.'config'.DIRECTORY_SEPARATOR.'rpc_routing.yml'; |
|
18 | 18 | $type = 'yaml'; |
19 | 19 | $importedRouters = $this->import($resource, $type); |
20 | 20 | $collection->addCollection($importedRouters); |
@@ -6,7 +6,6 @@ |
||
6 | 6 | use Cmobi\RabbitmqBundle\Rpc\Exception\JsonRpcInternalErrorException; |
7 | 7 | use Cmobi\RabbitmqBundle\Rpc\Response\JsonRpcResponse; |
8 | 8 | use Cmobi\RabbitmqBundle\Rpc\Response\RpcResponseCollectionInterface; |
9 | -use Cmobi\RabbitmqBundle\Rpc\Response\RpcResponseInterface; |
|
10 | 9 | use PhpAmqpLib\Message\AMQPMessage; |
11 | 10 | |
12 | 11 | class BaseService implements RpcServiceInterface |
@@ -41,7 +41,7 @@ |
||
41 | 41 | */ |
42 | 42 | public function createCallback() |
43 | 43 | { |
44 | - $callback = function (AMQPMessage $message) { |
|
44 | + $callback = function(AMQPMessage $message) { |
|
45 | 45 | |
46 | 46 | $responseCollection = $this->rpcMessager->getResponseCollection(); |
47 | 47 | $requestCollection = $this->rpcMessager->getRequestCollection(); |
@@ -19,7 +19,7 @@ |
||
19 | 19 | /** |
20 | 20 | * @var JsonRpcResponseCollection $responses |
21 | 21 | */ |
22 | - // $responses = $this->getMockBuilder('Cmobi\RabbitmqBundle\Rpc\Response\JsonRpcResponseCollection')->getMock(); |
|
22 | + // $responses = $this->getMockBuilder('Cmobi\RabbitmqBundle\Rpc\Response\JsonRpcResponseCollection')->getMock(); |
|
23 | 23 | /** |
24 | 24 | * @var AMQPMessage |
25 | 25 | */ |
@@ -24,7 +24,7 @@ |
||
24 | 24 | { |
25 | 25 | $keys = array_intersect_key($parameters, array_flip($this->requiredFields)); |
26 | 26 | |
27 | - if (count($this->requiredFields) != count($keys)) { |
|
27 | + if (count($this->requiredFields) != count($keys)) { |
|
28 | 28 | throw new JsonRpcInvalidParamsException(); |
29 | 29 | } |
30 | 30 |
@@ -7,7 +7,6 @@ |
||
7 | 7 | use Cmobi\RabbitmqBundle\Rpc\Exception\JsonRpcInternalErrorException; |
8 | 8 | use Cmobi\RabbitmqBundle\Rpc\Request\RpcRequestCollectionInterface; |
9 | 9 | use Cmobi\RabbitmqBundle\Rpc\Response\JsonRpcResponse; |
10 | -use Cmobi\RabbitmqBundle\Rpc\Response\JsonRpcResponseCollection; |
|
11 | 10 | use Cmobi\RabbitmqBundle\Rpc\Response\RpcResponseCollectionInterface; |
12 | 11 | use Symfony\Component\DependencyInjection\ContainerAwareTrait; |
13 | 12 |