Fix serviceName not set

Issue: BB-561
scality · Nov 13, 2024 · 933bd26 · 933bd26
1 parent 277809c
commit 933bd26
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 0 deletions.
diff --git a/extensions/notification/queueProcessor/QueueProcessor.js b/extensions/notification/queueProcessor/QueueProcessor.js
@@ -14,6 +14,7 @@ const NotificationDestination = require('../destination');
 const configUtil = require('../utils/config');
 const messageUtil = require('../utils/message');
 const NotificationConfigManager = require('../NotificationConfigManager');
+const libConstants = require('../../../lib/constants');
 
 const processedEvents = ZenkoMetrics.createCounter({
     name: 's3_notification_queue_processor_events_total',
@@ -92,6 +93,7 @@ class QueueProcessor extends EventEmitter {
         this.kafkaConfig = kafkaConfig;
         this.notifConfig = notifConfig;
         this.destinationId = destinationId;
+        this.serviceName = libConstants.services.notificationQueueProcessor;
         this.destinationConfig
             = notifConfig.destinations.find(dest => dest.resource === destinationId);
         assert(this.destinationConfig, `Invalid destination argument "${destinationId}".` +

diff --git a/extensions/replication/replicationStatusProcessor/ReplicationStatusProcessor.js b/extensions/replication/replicationStatusProcessor/ReplicationStatusProcessor.js
@@ -18,6 +18,7 @@ const FailedCRRProducer = require('../failedCRR/FailedCRRProducer');
 const ReplayProducer = require('../replay/ReplayProducer');
 const MetricsProducer = require('../../../lib/MetricsProducer');
 const { http: HttpAgent, https: HttpsAgent } = require('httpagent');
+const libConstants = require('../../../lib/constants');
 
 // StatsClient constant default for site metrics
 const INTERVAL = 300; // 5 minutes;
@@ -225,6 +226,7 @@ class ReplicationStatusProcessor {
         this._consumer = null;
         this._gcProducer = null;
         this._mProducer = null;
+        this.serviceName = libConstants.services.replicationStatusProcessor;
 
         this.logger =
             new Logger('Backbeat:Replication:ReplicationStatusProcessor');

diff --git a/lib/constants.js b/lib/constants.js
@@ -23,6 +23,7 @@ const constants = {
         replicationQueueProcessor: 'ReplicationQueueProcessor',
         replicationReplayProcessor: 'ReplicationReplayProcessor',
         replicationStatusProcessor: 'ReplicationStatusProcessor',
+        notificationQueueProcessor: 'NotificationQueueProcessor',
     },
     locationStatusCollection: '__locationStatusStore',
     lifecycleListing: {