From 23fe5f2dc574f36c17a6308da92858bc0420c1b8 Mon Sep 17 00:00:00 2001
From: jbernste <jbernste@apache.org>
Date: Sun, 7 Feb 2016 20:41:02 -0500
Subject: [PATCH] SOLR-8655: DaemonStream should 'put' EOF Tuple on the
 blocking queue

---
 .../apache/solr/client/solrj/io/stream/DaemonStream.java    | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/DaemonStream.java b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/DaemonStream.java
index 2d96c09bc55..358eea4a509 100644
--- a/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/DaemonStream.java
+++ b/solr/solrj/src/java/org/apache/solr/client/solrj/io/stream/DaemonStream.java
@@ -282,7 +282,11 @@ public class DaemonStream extends TupleStream implements Expressible {
         Map m = new HashMap();
         m.put("EOF", true);
         Tuple tuple = new Tuple(m);
-        queue.offer(tuple);
+        try {
+          queue.put(tuple);
+        } catch (InterruptedException e) {
+          logger.error("Error in DaemonStream", e);
+        }
       }
       setStopTime(new Date().getTime());
     }