summaryrefslogtreecommitdiffstats
path: root/vespa-http-client/src/test/java/ExampleUsageFeedClientTest.java
diff options
context:
space:
mode:
Diffstat (limited to 'vespa-http-client/src/test/java/ExampleUsageFeedClientTest.java')
-rw-r--r--vespa-http-client/src/test/java/ExampleUsageFeedClientTest.java13
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.");
}
+
}