diff options
author | Bjørn Christian Seime <bjorncs@vespa.ai> | 2024-05-28 11:38:19 +0200 |
---|---|---|
committer | Bjørn Christian Seime <bjorncs@vespa.ai> | 2024-05-28 11:38:19 +0200 |
commit | d09be5c926f822a3562a1300bbe5d64c61cf5baf (patch) | |
tree | 81d8e69fa828579ff0a83f178fcdd27ea1b68bff /vespa-feed-client | |
parent | 29f0ff655728d397507b36de0ba355e61c0843f6 (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.java | 7 |
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())); |