Browse Source

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
(cherry picked from commit 26e8bb4cc9)
tags/12.1.3^0
shenjiatong 3 months ago
committed by norman shen
parent
commit
360deb89a7
1 changed files with 3 additions and 1 deletions
  1. +3
    -1
      oslo_messaging/_drivers/impl_rabbit.py

+ 3
- 1
oslo_messaging/_drivers/impl_rabbit.py View File

@@ -26,6 +26,7 @@ import threading
import time
import uuid

from amqp import exceptions as amqp_exec
import kombu
import kombu.connection
import kombu.entity
@@ -1012,7 +1013,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()


Loading…
Cancel
Save