From 144eb9bf5517dbb20fe8dbfe3791faaba20707aa Mon Sep 17 00:00:00 2001 From: dehora Date: Wed, 22 Mar 2017 17:16:45 +0100 Subject: [PATCH] Cleans up consumer custom header submission test. --- .../src/test/java/nakadi/StreamProcessorTest.java | 8 -------- 1 file changed, 8 deletions(-) diff --git a/nakadi-java-client/src/test/java/nakadi/StreamProcessorTest.java b/nakadi-java-client/src/test/java/nakadi/StreamProcessorTest.java index 6d9f7826..154b9e71 100644 --- a/nakadi-java-client/src/test/java/nakadi/StreamProcessorTest.java +++ b/nakadi-java-client/src/test/java/nakadi/StreamProcessorTest.java @@ -76,17 +76,11 @@ public void customHeadersWithEventStream() throws Exception { .build(); processor.start(); - Thread.sleep(1000L); - processor.stop(); RecordedRequest request = server.takeRequest(); TestCase.assertEquals("gzip", request.getHeaders().get("Accept-Encoding")); - - - System.out.println(request.getHeaders().names()); - } @Test @@ -120,9 +114,7 @@ public void customHeadersWithSubscriptionStream() throws Exception { .build(); processor.start(); - Thread.sleep(1000L); - processor.stop(); RecordedRequest request = server.takeRequest();