aboutsummaryrefslogtreecommitdiffstats
path: root/vespa-feed-client
diff options
context:
space:
mode:
authorBjørn Christian Seime <bjorncs@vespa.ai>2024-05-28 11:38:19 +0200
committerBjørn Christian Seime <bjorncs@vespa.ai>2024-05-28 11:38:19 +0200
commitd09be5c926f822a3562a1300bbe5d64c61cf5baf (patch)
tree81d8e69fa828579ff0a83f178fcdd27ea1b68bff /vespa-feed-client
parent29f0ff655728d397507b36de0ba355e61c0843f6 (diff)
Add debug logging of request/response
Diffstat (limited to 'vespa-feed-client')
-rw-r--r--vespa-feed-client/src/main/java/ai/vespa/feed/client/impl/JettyCluster.java7
1 files changed, 7 insertions, 0 deletions
diff --git a/vespa-feed-client/src/main/java/ai/vespa/feed/client/impl/JettyCluster.java b/vespa-feed-client/src/main/java/ai/vespa/feed/client/impl/JettyCluster.java
index bfa04425369..6f438e33238 100644
--- a/vespa-feed-client/src/main/java/ai/vespa/feed/client/impl/JettyCluster.java
+++ b/vespa-feed-client/src/main/java/ai/vespa/feed/client/impl/JettyCluster.java
@@ -111,9 +111,16 @@ class JettyCluster implements Cluster {
}
jettyReq.body(new BytesRequestContent(APPLICATION_JSON.asString(), bytes));
}
+ log.log(Level.FINER, () ->
+ String.format("Dispatching request %s (%s)", req, System.identityHashCode(vessel)));
jettyReq.send(new BufferingResponseListener() {
@Override
public void onComplete(Result result) {
+ log.log(Level.FINER, () ->
+ String.format("Completed request %s (%s): %s",
+ req, System.identityHashCode(vessel),
+ result.isFailed()
+ ? result.getFailure().toString() : result.getResponse().getStatus()));
endpoint.inflight.decrementAndGet();
if (result.isFailed()) vessel.completeExceptionally(result.getFailure());
else vessel.complete(new JettyResponse(result.getResponse(), getContent()));