add test for bulk without any request holiding a pipeline id
This commit is contained in:
parent
21c89e6c5b
commit
fad2571ba5
|
@ -85,6 +85,19 @@ public class IngestActionFilterTests extends ESTestCase {
|
||||||
verifyZeroInteractions(executionService, actionFilterChain);
|
verifyZeroInteractions(executionService, actionFilterChain);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public void testApplyBulkNoPipelineId() throws Exception {
|
||||||
|
BulkRequest bulkRequest = new BulkRequest();
|
||||||
|
bulkRequest.add(new IndexRequest());
|
||||||
|
Task task = mock(Task.class);
|
||||||
|
ActionListener actionListener = mock(ActionListener.class);
|
||||||
|
ActionFilterChain actionFilterChain = mock(ActionFilterChain.class);
|
||||||
|
|
||||||
|
filter.apply(task, BulkAction.NAME, bulkRequest, actionListener, actionFilterChain);
|
||||||
|
|
||||||
|
verify(actionFilterChain).proceed(task, BulkAction.NAME, bulkRequest, actionListener);
|
||||||
|
verifyZeroInteractions(executionService, actionFilterChain);
|
||||||
|
}
|
||||||
|
|
||||||
@SuppressWarnings("unchecked")
|
@SuppressWarnings("unchecked")
|
||||||
public void testApplyIngestIdViaRequestParam() throws Exception {
|
public void testApplyIngestIdViaRequestParam() throws Exception {
|
||||||
Task task = mock(Task.class);
|
Task task = mock(Task.class);
|
||||||
|
|
Loading…
Reference in New Issue