We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 01a942d commit 38c0bebCopy full SHA for 38c0beb
pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/BrokerRegistryImpl.java
@@ -197,16 +197,17 @@ public synchronized void close() throws PulsarServerException {
197
return;
198
}
199
try {
200
+ this.listeners.clear();
201
this.unregister();
202
this.brokerLookupDataLockManager.close();
- this.listeners.clear();
203
- this.state = State.Closed;
204
} catch (Exception ex) {
205
if (ex.getCause() instanceof MetadataStoreException.NotFoundException) {
206
throw new PulsarServerException.NotFoundException(MetadataStoreException.unwrap(ex));
207
} else {
208
throw new PulsarServerException(MetadataStoreException.unwrap(ex));
209
+ } finally {
210
+ this.state = State.Closed;
211
212
213
0 commit comments