@@ -3,7 +3,6 @@ |
||
3 | 3 | namespace Mouf\AmqpClient; |
4 | 4 | |
5 | 5 | use PhpAmqpLib\Connection\AbstractConnection; |
6 | -use PhpAmqpLib\Connection\AMQPSocketConnection; |
|
7 | 6 | use PhpAmqpLib\Connection\AMQPStreamConnection; |
8 | 7 | use PhpAmqpLib\Channel\AMQPChannel; |
9 | 8 | use Mouf\AmqpClient\Exception\ConnectionException; |
@@ -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 | } |