@@ -115,7 +115,7 @@ discard block |
||
115 | 115 | |
116 | 116 | |
117 | 117 | |
118 | - $this->loopConnection(function () use ($sleepSeconds, $queueName) { |
|
118 | + $this->loopConnection(function() use ($sleepSeconds, $queueName) { |
|
119 | 119 | |
120 | 120 | $this->createQueue($queueName); |
121 | 121 | |
@@ -128,7 +128,7 @@ discard block |
||
128 | 128 | false, |
129 | 129 | false, |
130 | 130 | false, |
131 | - function (AMQPMessage $message) { |
|
131 | + function(AMQPMessage $message) { |
|
132 | 132 | pcntl_sigprocmask(SIG_BLOCK, [SIGTERM, SIGINT]); |
133 | 133 | |
134 | 134 | $incomeData = json_decode($message->getBody(), true); |