openstack
/
oslo.messaging
Code Issues Proposed changes

Catch ConnectionForced Exception 

Occasionally I saw large number of connectionforced exceptions.
such exceptions cannot be healed automatically and requires a reboot.
catch it and ensure connection established.

Change-Id: I5c468d10230f05438df780e045f1e92662edf070
Closes-Bug: #1883038
This commit is contained in:
shenjiatong 2020-06-30 08:56:26 +08:00 committed by ushen
parent c2074e4760
commit 26e8bb4cc9
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
oslo_messaging/_drivers/impl_rabbit.py
View File

@ -27,6 +27,7 @@ import time
from urllib import parse
import uuid
from amqp import exceptions as amqp_exec
import kombu
import kombu.connection
import kombu.entity
@ -1010,7 +1011,8 @@ class Connection(object):
except (socket.timeout,
ConnectRefuseError,
OSError,
kombu.exceptions.OperationalError) as exc:
kombu.exceptions.OperationalError,
amqp_exec.ConnectionForced) as exc:
LOG.info("A recoverable connection/channel error "
"occurred, trying to reconnect: %s", exc)
self.ensure_connection()