diff options
Diffstat (limited to 'vespa-http-client/src/test/java/ExampleUsageFeedClientTest.java')
-rw-r--r-- | vespa-http-client/src/test/java/ExampleUsageFeedClientTest.java | 13 |
1 files changed, 6 insertions, 7 deletions
diff --git a/vespa-http-client/src/test/java/ExampleUsageFeedClientTest.java b/vespa-http-client/src/test/java/ExampleUsageFeedClientTest.java index 238f6a91e53..909131a8979 100644 --- a/vespa-http-client/src/test/java/ExampleUsageFeedClientTest.java +++ b/vespa-http-client/src/test/java/ExampleUsageFeedClientTest.java @@ -16,6 +16,7 @@ import java.util.concurrent.atomic.AtomicInteger; /** * Unit test that test documentation code. + * * @author dybis */ public class ExampleUsageFeedClientTest { @@ -45,7 +46,7 @@ public class ExampleUsageFeedClientTest { // Example usage of FeedClient public static void exampleCode(String hostNameA, int portServerA, String hostNameB, int portServerB) { - final boolean useSsl = false; + boolean useSsl = false; final SessionParams sessionParams = new SessionParams.Builder() .addCluster(new Cluster.Builder().addEndpoint(Endpoint.create(hostNameA, portServerA, useSsl)).build()) .addCluster(new Cluster.Builder().addEndpoint(Endpoint.create(hostNameB, portServerB, useSsl)).build()) @@ -54,8 +55,8 @@ public class ExampleUsageFeedClientTest { .build()) .build(); - final AtomicInteger resultsReceived = new AtomicInteger(0); - final AtomicInteger errorsReceived = new AtomicInteger(0); + AtomicInteger resultsReceived = new AtomicInteger(0); + AtomicInteger errorsReceived = new AtomicInteger(0); FeedClient feedClient = FeedClientFactory.create(sessionParams, new FeedClient.ResultCallback() { @Override @@ -72,15 +73,13 @@ public class ExampleUsageFeedClientTest { } }); int sentCounter = 0; - final List<String> docIds = Arrays.asList("1", "2", "3", "4"); + List<String> docIds = Arrays.asList("1", "2", "3", "4"); for (final String docId : docIds) { CharSequence docData = generateDocument(docId); feedClient.stream(docId, docData, docId); sentCounter++; - System.out.println("Sent " + sentCounter + " received results from " + resultsReceived.get()); } feedClient.close(); - System.out.println("Finished, got " + errorsReceived.get() - + " errors from " + resultsReceived.get() + " results, sent " + sentCounter + " documents."); } + } |