[squash] Handle different configs

scality · May 29, 2018 · b985d3c · b985d3c
1 parent 9dac495
commit b985d3c
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 0 deletions.
diff --git a/conf/config.json b/conf/config.json
@@ -79,6 +79,7 @@
             "topic": "backbeat-replication",
             "replicationStatusTopic": "backbeat-replication-status",
             "replicationFailedTopic": "backbeat-replication-failed",
+            "monitorReplicationFailures": true,
             "queueProcessor": {
                 "groupId": "backbeat-replication-group",
                 "retryTimeoutS": 300,

diff --git a/extensions/replication/replicationStatusProcessor/ReplicationStatusProcessor.js b/extensions/replication/replicationStatusProcessor/ReplicationStatusProcessor.js
@@ -183,6 +183,10 @@ class ReplicationStatusProcessor {
                     sourceEntry.getCanonicalKey(), next),
             ], done);
         }
+        if (task) {
+            return this.taskScheduler.push({ task, entry: sourceEntry },
+                sourceEntry.getCanonicalKey(), done);
+        }
         this.logger.warn('skipping unknown source entry',
                          { entry: sourceEntry.getLogInfo() });
         return process.nextTick(done);

diff --git a/tests/config.json b/tests/config.json
@@ -42,6 +42,7 @@
         "replication": {
             "topic": "backbeat-test-replication",
             "replicationStatusTopic": "backbeat-test-replication-status",
+            "monitorReplicationFailures": true,
             "groupId": "backbeat-test-replication-group",
             "destination": {
                 "bootstrapList": [