[SEARCH-2109]

Restored shardState with corename parameter
This commit is contained in:
eliaporciani
2020-03-24 17:11:54 +01:00
parent 0e2e7608f1
commit 701d2fe45c
@@ -197,7 +197,10 @@ public abstract class CoreStatePublisher extends AbstractTracker
.map(Tracker::getTrackerState)
.orElse(transactionsTrackerState);
HashMap<String, String> extendedPropertyBag = new HashMap<>();
HashMap<String, String> propertyBag = new HashMap<>();
propertyBag.put("coreName", coreName);
HashMap<String, String> 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()