View GitHub Repository CmobiRabbitmqBundle

Schedule Inspection
Subscribe
Passed
Push — master ( 16ff6a...7b870f )
by Daniel
12:39
created
Status
Category
Toggle Patches
Transport/Rpc/RpcClient.php 1 patch
Spacing   +5 added lines, -5 removed lines patch added patch discarded remove patch 
@@ -46,7 +46,7 @@  discard block
 
 block discarded – undo
46 46 
      */
47 47 
     public function refreshChannel()
48 48 
     {
49 
-        if (! $this->connection->isConnected()) {
49 
+        if (!$this->connection->isConnected()) {
50 50 
             $this->connection->reconnect();
51 51 
         }
52 52 
         $this->channel = $this->connection->channel();
 
@@ -66,7 +66,7 @@  discard block
 
 block discarded – undo
66 66 
         $this->response = null;
67 67 
         $this->refreshChannel();
68 68
69 
-        if (! $this->queueHasExists()) {
69 
+        if (!$this->queueHasExists()) {
70 70 
             throw new QueueNotFoundException("Queue $this->queueName not declared.");
71 71 
         }
72 72 
         $this->correlationId = $this->generateCorrelationId();
 
@@ -91,7 +91,7 @@  discard block
 
 block discarded – undo
91 91 
             [$this, 'onResponse']
92 92 
         );
93 93 
         $msg = new CmobiAMQPMessage(
94 
-            (string) $data,
94 
+            (string)$data,
95 95 
             [
96 96 
                 'correlation_id' => $this->correlationId,
97 97 
                 'reply_to' => $this->callbackQueue,
 
@@ -100,7 +100,7 @@  discard block
 
 block discarded – undo
100 100 
         );
101 101 
         $this->getChannel()->basic_publish($msg, '', $this->getQueueName());
102 102
103 
-        while (! $this->response) {
103 
+        while (!$this->response) {
104 104 
             $this->getChannel()->wait(null, 0, ($expire / 1000));
105 105 
         }
106 106 
         $this->getChannel()->close();
 
@@ -166,7 +166,7 @@  discard block
 
 block discarded – undo
166 166 
     /** @return string */
167 167 
     public function generateCorrelationId()
168 168 
     {
169 
-        return uniqid($this->getQueueName()) . Uuid::uuid4()->toString() . microtime();
169 
+        return uniqid($this->getQueueName()).Uuid::uuid4()->toString().microtime();
170 170 
     }
171 171
172 172 
     /**
Please login to merge, or discard this patch.