diff --git a/service/src/main/java/org/sunbird/actor/user/UserDeletionBackgroundJobActor.java b/service/src/main/java/org/sunbird/actor/user/UserDeletionBackgroundJobActor.java index 55717ffd4f..326b401969 100644 --- a/service/src/main/java/org/sunbird/actor/user/UserDeletionBackgroundJobActor.java +++ b/service/src/main/java/org/sunbird/actor/user/UserDeletionBackgroundJobActor.java @@ -14,6 +14,7 @@ import org.sunbird.service.user.UserService; import org.sunbird.service.user.impl.UserServiceImpl; import org.sunbird.util.PropertiesCache; +import org.sunbird.util.user.UserUtil; public class UserDeletionBackgroundJobActor extends BaseActor { @@ -32,7 +33,7 @@ private void inputKafkaTopic(Request request) throws Exception { logger.info("UserDeletionBackgroundJobActor::inputKafkaTopic:: roles size:: " + roles.size()); User user = userService.getUserById(userId, request.getRequestContext()); String rootOrgId = user.getRootOrgId(); - String userName = user.getUserName(); + String userName = UserUtil.getDecryptedData(user.getUserName(), request.getRequestContext()); List> suggestedUsersList = new ArrayList<>(); Map searchQueryMap = new HashMap<>();