|
@@ -50,8 +50,6 @@ public class RestNoopBulkAction extends BaseRestHandler {
|
|
|
controller.registerHandler(PUT, "/_noop_bulk", this);
|
|
|
controller.registerHandler(POST, "/{index}/_noop_bulk", this);
|
|
|
controller.registerHandler(PUT, "/{index}/_noop_bulk", this);
|
|
|
- controller.registerHandler(POST, "/{index}/{type}/_noop_bulk", this);
|
|
|
- controller.registerHandler(PUT, "/{index}/{type}/_noop_bulk", this);
|
|
|
}
|
|
|
|
|
|
@Override
|
|
@@ -63,7 +61,6 @@ public class RestNoopBulkAction extends BaseRestHandler {
|
|
|
public RestChannelConsumer prepareRequest(final RestRequest request, final NodeClient client) throws IOException {
|
|
|
BulkRequest bulkRequest = Requests.bulkRequest();
|
|
|
String defaultIndex = request.param("index");
|
|
|
- String defaultType = request.param("type");
|
|
|
String defaultRouting = request.param("routing");
|
|
|
String defaultPipeline = request.param("pipeline");
|
|
|
|
|
@@ -73,7 +70,7 @@ public class RestNoopBulkAction extends BaseRestHandler {
|
|
|
}
|
|
|
bulkRequest.timeout(request.paramAsTime("timeout", BulkShardRequest.DEFAULT_TIMEOUT));
|
|
|
bulkRequest.setRefreshPolicy(request.param("refresh"));
|
|
|
- bulkRequest.add(request.requiredContent(), defaultIndex, defaultType, defaultRouting,
|
|
|
+ bulkRequest.add(request.requiredContent(), defaultIndex, defaultRouting,
|
|
|
null, defaultPipeline, true, request.getXContentType());
|
|
|
|
|
|
// short circuit the call to the transport layer
|