diff --git a/search-services/alfresco-search/src/main/java/org/alfresco/solr/tracker/CoreStatePublisher.java b/search-services/alfresco-search/src/main/java/org/alfresco/solr/tracker/CoreStatePublisher.java index a6b727d3c..591863964 100644 --- a/search-services/alfresco-search/src/main/java/org/alfresco/solr/tracker/CoreStatePublisher.java +++ b/search-services/alfresco-search/src/main/java/org/alfresco/solr/tracker/CoreStatePublisher.java @@ -197,7 +197,10 @@ public abstract class CoreStatePublisher extends AbstractTracker .map(Tracker::getTrackerState) .orElse(transactionsTrackerState); - HashMap extendedPropertyBag = new HashMap<>(); + HashMap propertyBag = new HashMap<>(); + propertyBag.put("coreName", coreName); + + HashMap extendedPropertyBag = new HashMap<>(propertyBag); updateShardProperty(); extendedPropertyBag.putAll(docRouter.getProperties(shardProperty)); @@ -222,6 +225,7 @@ public abstract class CoreStatePublisher extends AbstractTracker .withTemplate(shardTemplate) .withHasContent(transformContent) .withShardMethod(ShardMethodEnum.getShardMethod(shardMethod)) + .withPropertyBag(propertyBag) .endFloc() .endShard() .endShardInstance()