|
@@ -115,7 +115,7 @@ discard block |
|
|
block discarded – undo |
|
115
|
115
|
$this->validateExecuteCallback(); |
|
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 |
|
|
block discarded – undo |
|
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); |
Please login to merge, or discard this patch.