improved network handling
This commit is contained in:
@@ -38,7 +38,7 @@ class Publisher:
|
|||||||
self._connect()
|
self._connect()
|
||||||
try:
|
try:
|
||||||
self._publish(msg, headers)
|
self._publish(msg, headers)
|
||||||
except pika.exceptions.ConnectionClosed:
|
except (pika.exceptions.ConnectionClosed, pika.exceptions.StreamLostError):
|
||||||
self._logger.info('reconnecting to queue')
|
self._logger.info('reconnecting to queue')
|
||||||
self._connect()
|
self._connect()
|
||||||
self._publish(msg, headers)
|
self._publish(msg, headers)
|
||||||
|
Reference in New Issue
Block a user