@@ -308,7 +308,7 @@ discard block |
||
308 | 308 | $this->connection_timeout, |
309 | 309 | $this->read_write_timeout, |
310 | 310 | $this->context, |
311 | - $this->keepalive , |
|
311 | + $this->keepalive, |
|
312 | 312 | $this->heartbeat |
313 | 313 | ); |
314 | 314 | } else { |
@@ -325,7 +325,7 @@ discard block |
||
325 | 325 | $this->connection_timeout, |
326 | 326 | $this->read_write_timeout, |
327 | 327 | $this->context, |
328 | - $this->keepalive , |
|
328 | + $this->keepalive, |
|
329 | 329 | $this->heartbeat |
330 | 330 | ); |
331 | 331 | } |
@@ -359,7 +359,7 @@ discard block |
||
359 | 359 | */ |
360 | 360 | public function getQueues() |
361 | 361 | { |
362 | - return array_filter($this->rabbitMqObjects, function (RabbitMqObjectInterface $object) { |
|
362 | + return array_filter($this->rabbitMqObjects, function(RabbitMqObjectInterface $object) { |
|
363 | 363 | return $object instanceof QueueInterface; |
364 | 364 | }); |
365 | 365 | } |