|
@@ -38,7 +38,7 @@ discard block |
|
|
block discarded – undo |
|
38
|
38
|
'lazy' => true, |
|
39
|
39
|
|
|
40
|
40
|
# More info about timeouts can be found on https://www.rabbitmq.com/networking.html |
|
41
|
|
- 'read_write_timeout' => 3, // default timeout for writing/reading (in seconds) |
|
|
41
|
+ 'read_write_timeout' => 3, // default timeout for writing/reading (in seconds) |
|
42
|
42
|
'connect_timeout' => 3, |
|
43
|
43
|
'heartbeat' => 0, |
|
44
|
44
|
'keep_alive' => false, |
|
@@ -218,7 +218,7 @@ discard block |
|
|
block discarded – undo |
|
218
|
218
|
$this->getConnection()->reconnect(); |
|
219
|
219
|
} catch (AMQPChannelClosedException $e) { |
|
220
|
220
|
$this->logger->info('channel was closed'); |
|
221
|
|
- } catch (AMQPConnectionClosedException $e){ |
|
|
221
|
+ } catch (AMQPConnectionClosedException $e) { |
|
222
|
222
|
$this->getConnection()->reconnect(); |
|
223
|
223
|
$this->logger->info('connection was closed'); |
|
224
|
224
|
} |
Please login to merge, or discard this patch.