[pulsar] branch branch-2.11 updated: [fix][broker] AbstractBatchedMetadataStore - use AlreadyClosedException instead of IllegalStateException (#19284)

[eolivelli]

This is an automated email from the ASF dual-hosted git repository.

eolivelli pushed a commit to branch branch-2.11
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/branch-2.11 by this push:
     new 58e87d150ce [fix][broker] AbstractBatchedMetadataStore - use 
AlreadyClosedException instead of IllegalStateException (#19284)
58e87d150ce is described below

commit 58e87d150ce5d986e34c52dfbde391affe1a4faf
Author: Enrico Olivelli <eolive...@apache.org>
AuthorDate: Thu Jan 19 14:35:00 2023 +0100

    [fix][broker] AbstractBatchedMetadataStore - use AlreadyClosedException 
instead of IllegalStateException (#19284)
    
    (cherry picked from commit d3e112e94ae251fb3ee7668061d336e0400f9a5c)
---
 .../pulsar/metadata/impl/batching/AbstractBatchedMetadataStore.java   | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/batching/AbstractBatchedMetadataStore.java
 
b/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/batching/AbstractBatchedMetadataStore.java
index c9d245b8caf..f0a6dc426cc 100644
--- 
a/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/batching/AbstractBatchedMetadataStore.java
+++ 
b/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/batching/AbstractBatchedMetadataStore.java
@@ -31,6 +31,7 @@ import lombok.extern.slf4j.Slf4j;
 import org.apache.pulsar.metadata.api.GetResult;
 import org.apache.pulsar.metadata.api.MetadataEventSynchronizer;
 import org.apache.pulsar.metadata.api.MetadataStoreConfig;
+import org.apache.pulsar.metadata.api.MetadataStoreException;
 import org.apache.pulsar.metadata.api.Stat;
 import org.apache.pulsar.metadata.api.extended.CreateOption;
 import org.apache.pulsar.metadata.impl.AbstractMetadataStore;
@@ -80,7 +81,8 @@ public abstract class AbstractBatchedMetadataStore extends 
AbstractMetadataStore
     public void close() throws Exception {
         if (enabled) {
             // Fail all the pending items
-            Exception ex = new IllegalStateException("Metadata store is 
getting closed");
+            MetadataStoreException ex =
+                    new 
MetadataStoreException.AlreadyClosedException("Metadata store is getting 
closed");
             readOps.drain(op -> op.getFuture().completeExceptionally(ex));
             writeOps.drain(op -> op.getFuture().completeExceptionally(ex));