From af4891e7c47634a9b36fd07ef672fb49d4d5e9ed Mon Sep 17 00:00:00 2001 From: Jon Marius Venstad Date: Mon, 28 Jun 2021 13:16:33 +0200 Subject: Actually reject new operations after close() is called --- .../src/main/java/ai/vespa/feed/client/HttpFeedClient.java | 3 +++ 1 file changed, 3 insertions(+) (limited to 'vespa-feed-client') 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 e3a8a6af9b0..143f51a9bf7 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 @@ -76,6 +76,9 @@ class HttpFeedClient implements FeedClient { } private CompletableFuture send(String method, DocumentId documentId, String operationJson, OperationParameters params) { + if (closed.get()) + throw new IllegalStateException("Client is closed"); + HttpRequest request = new HttpRequest(method, getPath(documentId) + getQuery(params), requestHeaders, -- cgit v1.2.3