diff options
Diffstat (limited to 'vespa-feed-client/src/main/java/ai/vespa/feed/client/HttpFeedClient.java')
-rw-r--r-- | vespa-feed-client/src/main/java/ai/vespa/feed/client/HttpFeedClient.java | 15 |
1 files changed, 5 insertions, 10 deletions
diff --git a/vespa-feed-client/src/main/java/ai/vespa/feed/client/HttpFeedClient.java b/vespa-feed-client/src/main/java/ai/vespa/feed/client/HttpFeedClient.java index 256d3ae535c..b160cced4b9 100644 --- a/vespa-feed-client/src/main/java/ai/vespa/feed/client/HttpFeedClient.java +++ b/vespa-feed-client/src/main/java/ai/vespa/feed/client/HttpFeedClient.java @@ -63,6 +63,11 @@ class HttpFeedClient implements FeedClient { } @Override + public CircuitBreaker.State circuitBreakerState() { + return requestStrategy.circuitBreakerState(); + } + + @Override public void close(boolean graceful) { closed.set(true); if (graceful) @@ -71,17 +76,7 @@ class HttpFeedClient implements FeedClient { requestStrategy.destroy(); } - private void ensureOpen() { - if (requestStrategy.hasFailed()) - close(); - - if (closed.get()) - throw new IllegalStateException("Client is closed, no further operations may be sent"); - } - private CompletableFuture<Result> send(String method, DocumentId documentId, String operationJson, OperationParameters params) { - ensureOpen(); - HttpRequest request = new HttpRequest(method, getPath(documentId) + getQuery(params), requestHeaders, |