Make TCP publisher log warning instead of failing.

Change-Id: I56ca759c2d43830f4e342130f27b75bdba65c469
This commit is contained in:
Jaromír Wysoglad
2023-04-11 12:44:26 -04:00
parent 7dd58d6f75
commit 8699146e1a

View File

@@ -51,7 +51,11 @@ class TCPPublisher(publisher.ConfigPublisherBase):
"Cannot resolve host %s, creating AF_INET socket...",
self.host)
self.addr_family = socket.AF_INET
self.create_and_connect()
try:
self.create_and_connect()
except Exception:
LOG.error(_("Unable to connect to the "
"remote endpoint"))
def create_and_connect(self):
self.socket = socket.socket(self.addr_family,
@@ -77,8 +81,8 @@ class TCPPublisher(publisher.ConfigPublisherBase):
try:
self.socket.send(msg_len + encoded_msg)
except Exception:
LOG.warning(_("Unable to send sample over TCP,"
"trying to reconnect and resend the message"))
LOG.error(_("Unable to send sample over TCP,"
"trying to reconnect and resend the message"))
self.create_and_connect()
try:
self.socket.send(msg_len + encoded_msg)