@@ -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 | |