@@ -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 | } |