Add a parameter that will make the Q unbounded if producer == consumer.

The purpose is to avoid deadlocking with yourself.

1 files changed, 2 insertions, 2 deletions

diff --git a/vespa-http-client/src/test/java/com/yahoo/vespa/http/client/core/communication/CloseableQTestCase.java b/vespa-http-client/src/test/java/com/yahoo/vespa/http/client/core/communication/CloseableQTestCase.java
index 13129dba326..4148e652d55 100644
--- a/vespa-http-client/src/test/java/com/yahoo/vespa/http/client/core/communication/CloseableQTestCase.java
+++ b/vespa-http-client/src/test/java/com/yahoo/vespa/http/client/core/communication/CloseableQTestCase.java
@@ -10,7 +10,7 @@ public class CloseableQTestCase {
     @Test
     public void requestThatPutIsInterruptedOnClose() throws InterruptedException {
         final DocumentQueue q = new DocumentQueue(1);
-        q.put(new Document("id", "data", null /* context */));
+        q.put(new Document("id", "data", null /* context */), false);
         Thread t = new Thread(new Runnable() {
             @Override
             public void run() {
@@ -25,7 +25,7 @@ public class CloseableQTestCase {
         });
         t.start();
         try {
-            q.put(new Document("id2", "data2", null /* context */));
+            q.put(new Document("id2", "data2", null /* context */), false);
             fail("This shouldn't have worked.");
         } catch (IllegalStateException ise) {
             // ok!