honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

renamed variables

This commit is contained in:
Martijn van Groningen 2016-01-15 10:27:42 +01:00
parent 21cc0b2316
commit f8bb06a664
2 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
core/src/test/java/org/elasticsearch/action/ingest/IngestActionFilterTests.java
View File

@ -66,9 +66,9 @@ public class IngestActionFilterTests extends ESTestCase {
executionService = mock(PipelineExecutionService.class);
IngestService ingestService = mock(IngestService.class);
when(ingestService.getPipelineExecutionService()).thenReturn(executionService);
NodeService bootstrapper = mock(NodeService.class);
when(bootstrapper.getIngestService()).thenReturn(ingestService);
filter = new IngestActionFilter(Settings.EMPTY, bootstrapper);
NodeService nodeService = mock(NodeService.class);
when(nodeService.getIngestService()).thenReturn(ingestService);
filter = new IngestActionFilter(Settings.EMPTY, nodeService);
}
public void testApplyNoPipelineId() throws Exception {
@ -175,9 +175,9 @@ public class IngestActionFilterTests extends ESTestCase {
executionService = new PipelineExecutionService(store, threadPool);
IngestService ingestService = mock(IngestService.class);
when(ingestService.getPipelineExecutionService()).thenReturn(executionService);
NodeService bootstrapper = mock(NodeService.class);
when(bootstrapper.getIngestService()).thenReturn(ingestService);
filter = new IngestActionFilter(Settings.EMPTY, bootstrapper);
NodeService nodeService = mock(NodeService.class);
when(nodeService.getIngestService()).thenReturn(ingestService);
filter = new IngestActionFilter(Settings.EMPTY, nodeService);
BulkRequest bulkRequest = new BulkRequest();
int numRequest = scaledRandomIntBetween(8, 64);

4
core/src/test/java/org/elasticsearch/ingest/IngestClientIT.java
View File

@ -225,8 +225,8 @@ public class IngestClientIT extends ESIntegTestCase {
return "ingest mock";
}
public void onModule(NodeModule ingestModule) {
ingestModule.registerProcessor("test", (environment, templateService) -> config ->
public void onModule(NodeModule nodeModule) {
nodeModule.registerProcessor("test", (environment, templateService) -> config ->
new TestProcessor("test", ingestDocument -> {
ingestDocument.setFieldValue("processed", true);
if (ingestDocument.getFieldValue("fail", Boolean.class)) {