Skip to content
This repository was archived by the owner on Feb 5, 2024. It is now read-only.

Commit a63df39

Browse files
committed
Fix not part of keygroup bug
1 parent 0f18b22 commit a63df39

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

src/main/java/tasks/UpdateKeygroupSubscriptionsTask.java

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -13,6 +13,7 @@
1313
import model.config.KeygroupConfig;
1414
import model.config.NodeConfig;
1515
import model.config.ReplicaNodeConfig;
16+
import model.config.TriggerNodeConfig;
1617
import model.data.KeygroupID;
1718
import storageconnector.AbstractDBConnector;
1819
import tasks.TaskManager.TaskName;
@@ -65,6 +66,13 @@ public Boolean executeFunctionality() throws FBaseException {
6566
partOfKeygroup = true;
6667
}
6768
}
69+
if (!partOfKeygroup) {
70+
for (TriggerNodeConfig tn : config.getTriggerNodes()) {
71+
if (fBase.configuration.getNodeID().equals(tn.getNodeID())) {
72+
partOfKeygroup = true;
73+
}
74+
}
75+
}
6876

6977
// check is not tombstoned
7078
boolean active = true; // TODO 1: set value to !config.isTombstoned();

0 commit comments

Comments
 (0)