Split to dedicated redis messaging for peerLogMessaging

nickvsnetworking · Jan 27, 2024 · 30c56ed · 30c56ed
1 parent 9932588
commit 30c56ed
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/services/diameterService.py b/services/diameterService.py
@@ -32,6 +32,7 @@ def __init__(self):
         self.redisReaderMessaging = RedisMessagingAsync(host=self.redisHost, port=self.redisPort, useUnixSocket=self.redisUseUnixSocket, unixSocketPath=self.redisUnixSocketPath)
         self.redisWriterMessaging = RedisMessagingAsync(host=self.redisHost, port=self.redisPort, useUnixSocket=self.redisUseUnixSocket, unixSocketPath=self.redisUnixSocketPath)
         self.redisPeerMessaging = RedisMessagingAsync(host=self.redisHost, port=self.redisPort, useUnixSocket=self.redisUseUnixSocket, unixSocketPath=self.redisUnixSocketPath)
+        self.redisPeerLogMessaging = RedisMessagingAsync(host=self.redisHost, port=self.redisPort, useUnixSocket=self.redisUseUnixSocket, unixSocketPath=self.redisUnixSocketPath)
         self.redisMetricMessaging = RedisMessagingAsync(host=self.redisHost, port=self.redisPort, useUnixSocket=self.redisUseUnixSocket, unixSocketPath=self.redisUnixSocketPath)
         self.banners = Banners()
         self.logTool = LogTool(config=self.config)
@@ -114,7 +115,7 @@ async def logActivePeers(self):
                     peerConnectionStatus = peerData.get('connectionStatus', None)
                     if peerHost and peerConnectionStatus:
                         if peerConnectionStatus.lower() == 'connected':
-                            await(self.redisMetricMessaging.sendMetric(serviceName='diameter', metricName='prom_diam_connected_state',
+                            await(self.redisPeerLogMessaging.sendMetric(serviceName='diameter', metricName='prom_diam_connected_state',
                                     metricType='gauge', metricAction='set',
                                     metricLabels={'host': peerHost},
                                     metricValue=1.0, metricHelp='Connection state of diameter peers',
@@ -123,7 +124,7 @@ async def logActivePeers(self):
                                     prefixHostname=self.hostname, 
                                     prefixServiceName='metric'))
                         elif peerConnectionStatus.lower() == 'disconnected':
-                            await(self.redisMetricMessaging.sendMetric(serviceName='diameter', metricName='prom_diam_connected_state',
+                            await(self.redisPeerLogMessaging.sendMetric(serviceName='diameter', metricName='prom_diam_connected_state',
                                     metricType='gauge', metricAction='set',
                                     metricLabels={'host': peerHost},
                                     metricValue=0.0, metricHelp='Connection state of diameter peers',