Commit 0bda88e4 authored by tufengqi's avatar tufengqi

Merge branch 'fix-001' into 'master'

fix See merge request !1
parents 477327af e468ab85
...@@ -31,12 +31,13 @@ class AMQPStreamConnection extends AbstractConnection ...@@ -31,12 +31,13 @@ class AMQPStreamConnection extends AbstractConnection
$login_method = 'AMQPLAIN', $login_method = 'AMQPLAIN',
$login_response = null, $login_response = null,
$locale = 'en_US', $locale = 'en_US',
$connection_timeout = 3.0, $connection_timeout = 0,
$read_write_timeout = 3.0, $read_write_timeout = 3.0,
$context = null, $context = null,
$keepalive = false, $keepalive = false,
$heartbeat = 0 $heartbeat = 0
) { ) {
$connection_timeout = $connection_timeout ? : \Yii::$app->fpf->getConfig('mq_connect_time', 'common');
$io = new StreamIO( $io = new StreamIO(
$host, $host,
$port, $port,
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment