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