hazza/DSpace
1
0
Fork 0
mirror of https://github.com/DSpace/DSpace.git synced 2025-10-17 15:03:18 +00:00
Code Issues Packages Projects Releases Wiki Activity

added fix that able to delete solr record

Browse Source
This commit is contained in:
Mykhaylo
2021-03-11 10:47:35 +01:00
parent 6b87011377
commit 66a8b1c7df
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
dspace-api/src/main/java/org/dspace/discovery/IndexEventConsumer.java
View File

@@ -138,8 +138,9 @@ public class IndexEventConsumer implements Consumer {
// became directly an item without giving us the chance to retrieve a // became directly an item without giving us the chance to retrieve a
// workflowitem... so we need to force the unindex of all the related data // workflowitem... so we need to force the unindex of all the related data
// before to index it again to be sure to don't leave any zombie in solr // before to index it again to be sure to don't leave any zombie in solr
String detail = IndexFactory indexableObjectService = IndexObjectFactoryFactory.getInstance()
Constants.typeText[event.getSubjectType()] + "-" + event.getSubjectID().toString(); .getIndexFactoryByType(Constants.typeText[event.getSubjectType()]);
String detail = indexableObjectService.getType() + "-" + event.getSubjectID().toString();
uniqueIdsToDelete.add(detail); uniqueIdsToDelete.add(detail);
} }
objectsToUpdate.addAll(indexObjectServiceFactory.getIndexableObjects(ctx, subject)); objectsToUpdate.addAll(indexObjectServiceFactory.getIndexableObjects(ctx, subject));
@@ -163,7 +164,9 @@ public class IndexEventConsumer implements Consumer {
if (event.getSubjectType() == -1 || event.getSubjectID() == null) { if (event.getSubjectType() == -1 || event.getSubjectID() == null) {
log.warn("got null subject type and/or ID on DELETE event, skipping it."); log.warn("got null subject type and/or ID on DELETE event, skipping it.");
} else { } else {
String detail = Constants.typeText[event.getSubjectType()] + "-" + event.getSubjectID().toString(); IndexFactory indexableObjectService = IndexObjectFactoryFactory.getInstance()
.getIndexFactoryByType(Constants.typeText[event.getSubjectType()]);
String detail = indexableObjectService.getType() + "-" + event.getSubjectID().toString();
log.debug("consume() adding event to delete queue: " + event.toString()); log.debug("consume() adding event to delete queue: " + event.toString());
uniqueIdsToDelete.add(detail); uniqueIdsToDelete.add(detail);
} }