Commit e468ab85 authored by shajiaiming's avatar shajiaiming

fix

parent 477327af
......@@ -31,12 +31,13 @@ class AMQPStreamConnection extends AbstractConnection
$login_method = 'AMQPLAIN',
$login_response = null,
$locale = 'en_US',
$connection_timeout = 3.0,
$connection_timeout = 0,
$read_write_timeout = 3.0,
$context = null,
$keepalive = false,
$heartbeat = 0
) {
$connection_timeout = $connection_timeout ? : \Yii::$app->fpf->getConfig('mq_connect_time', 'common');
$io = new StreamIO(
$host,
$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