Fail with StorageException.Unavailable only when client is CLOSED
Change-Id: I5a7f7cdb78aee88662b421cbcc03ed3b39e1e7ab
Showing
1 changed file
with
1 additions
and
1 deletions
... | @@ -73,7 +73,7 @@ public class OnosCopycatClient extends DelegatingCopycatClient { | ... | @@ -73,7 +73,7 @@ public class OnosCopycatClient extends DelegatingCopycatClient { |
73 | 73 | ||
74 | @Override | 74 | @Override |
75 | public <T> CompletableFuture<T> submit(Query<T> query) { | 75 | public <T> CompletableFuture<T> submit(Query<T> query) { |
76 | - if (state() == State.SUSPENDED || state() == State.CLOSED) { | 76 | + if (state() == State.CLOSED) { |
77 | return Tools.exceptionalFuture(new StorageException.Unavailable()); | 77 | return Tools.exceptionalFuture(new StorageException.Unavailable()); |
78 | } | 78 | } |
79 | CompletableFuture<T> future = new CompletableFuture<>(); | 79 | CompletableFuture<T> future = new CompletableFuture<>(); | ... | ... |
-
Please register or login to post a comment