From fad2571ba527faab1f06f5d014cc2beac9ce76f5 Mon Sep 17 00:00:00 2001
From: javanna <cavannaluca@gmail.com>
Date: Mon, 11 Jan 2016 14:56:02 +0100
Subject: [PATCH] add test for bulk without any request holiding a pipeline id

---
 .../action/ingest/IngestActionFilterTests.java      | 13 +++++++++++++
 1 file changed, 13 insertions(+)

diff --git a/core/src/test/java/org/elasticsearch/action/ingest/IngestActionFilterTests.java b/core/src/test/java/org/elasticsearch/action/ingest/IngestActionFilterTests.java
index 040782968e7..d8663ade60b 100644
--- a/core/src/test/java/org/elasticsearch/action/ingest/IngestActionFilterTests.java
+++ b/core/src/test/java/org/elasticsearch/action/ingest/IngestActionFilterTests.java
@@ -85,6 +85,19 @@ public class IngestActionFilterTests extends ESTestCase {
         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")
     public void testApplyIngestIdViaRequestParam() throws Exception {
         Task task = mock(Task.class);