Skip to content

Commit 10ee519

Browse files
committed
project routing can be present in the body of the request
1 parent 0d6a886 commit 10ee519

File tree

2 files changed

+6
-1
lines changed

2 files changed

+6
-1
lines changed

server/src/main/java/org/elasticsearch/action/search/OpenPointInTimeRequest.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -212,7 +212,10 @@ public String getProjectRouting() {
212212
return projectRouting;
213213
}
214214

215-
public void projectRouting(String projectRouting) {
215+
public void projectRouting(@Nullable String projectRouting) {
216+
if (this.projectRouting != null) {
217+
throw new IllegalArgumentException("project_routing is already set to [" + this.projectRouting + "]");
218+
}
216219
this.projectRouting = projectRouting;
217220
}
218221

server/src/main/java/org/elasticsearch/action/search/RestOpenPointInTimeAction.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -83,8 +83,10 @@ public RestChannelConsumer prepareRequest(final RestRequest request, final NodeC
8383

8484
private static final ObjectParser<OpenPointInTimeRequest, Void> PARSER = new ObjectParser<>("open_point_in_time_request");
8585
private static final ParseField INDEX_FILTER_FIELD = new ParseField("index_filter");
86+
private static final ParseField PROJECT_ROUTING = new ParseField("project_routing");
8687

8788
static {
8889
PARSER.declareObject(OpenPointInTimeRequest::indexFilter, (p, c) -> parseTopLevelQuery(p), INDEX_FILTER_FIELD);
90+
PARSER.declareString(OpenPointInTimeRequest::projectRouting, PROJECT_ROUTING);
8991
}
9092
}

0 commit comments

Comments
 (0)