summaryrefslogtreecommitdiffstats
path: root/vespa-feed-client/src/main/java/ai/vespa/feed/client/HttpFeedClient.java
diff options
context:
space:
mode:
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.java15
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,