Improve code.

wso2-extensions · Dec 12, 2024 · 70f1c56 · 70f1c56
1 parent 95f71d6
commit 70f1c56
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/...org/wso2/carbon/identity/account/suspension/notification/task/AccountValidatorThread.java b/...org/wso2/carbon/identity/account/suspension/notification/task/AccountValidatorThread.java
@@ -90,7 +90,7 @@ private void handleTask(String tenantDomain) {
         }
 
         // Run the task only from master node in cluster setup.
-        if (isClusterModeEnabled() && !isHazelcastMasterNode()) {
+        if (isSingleNodeTaskExecutionEnabled() && !isHazelcastMasterNode()) {
             return;
         }
 
@@ -178,7 +178,7 @@ private void handleTask(String tenantDomain) {
      *
      * @return true or false based on the deployment config.
      */
-    private boolean isClusterModeEnabled() {
+    private boolean isSingleNodeTaskExecutionEnabled() {
 
         String clusterModeEnabledValue = IdentityUtil.getProperty(NotificationConstants.EXECUTE_TASK_IN_SINGLE_NODE);
         return StringUtils.isNotBlank(clusterModeEnabledValue) ? Boolean.parseBoolean(clusterModeEnabledValue) : false;

diff --git a/...ntity/account/suspension/notification/task/internal/NotificationTaskServiceComponent.java b/...ntity/account/suspension/notification/task/internal/NotificationTaskServiceComponent.java
@@ -164,6 +164,7 @@ protected void unsetRealmService(RealmService realmService) {
             policy = ReferencePolicy.DYNAMIC,
             unbind = "unsetClusteringAgent")
     protected void setClusteringAgent(ConfigurationContextService configurationContextService) {
+
         NotificationTaskDataHolder.getInstance().setClusteringAgent(
                 configurationContextService.getServerConfigContext().getAxisConfiguration().getClusteringAgent());
     }