Skip to content

Commit ce2e343

Browse files
committed
Adjust default parameter for streamconnection
1 parent 1532c02 commit ce2e343

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

Classes/Queue/RabbitQueue.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -60,7 +60,7 @@ public function __construct(string $name, array $options = [])
6060
$insist = isset($clientOptions['insist']) ? (bool) $clientOptions['insist'] : false;
6161
$loginMethod = isset($clientOptions['loginMethod']) ? (string) $clientOptions['loginMethod'] : 'AMQPLAIN';
6262

63-
$this->connection = new AMQPStreamConnection($host, $port, $username, $password, $vhost, $insist, $loginMethod, null, 'en_US', 3.0, 3.0, null, true);
63+
$this->connection = new AMQPStreamConnection($host, $port, $username, $password, $vhost, $insist, $loginMethod, null, 'en_US', 3.0, 130.0, null, true);
6464
$this->channel = $this->connection->channel();
6565

6666
// a worker should only get one message at a time

0 commit comments

Comments
 (0)