Skip to content

Commit

Permalink
[fix][broker] Unregister topic policy listener if managed ledger clos…
Browse files Browse the repository at this point in the history
…e failed (#17652)

(cherry picked from commit dc54997)
  • Loading branch information
codelipenghui authored and congbobo184 committed Nov 26, 2022
1 parent 38f0588 commit 668f6d4
Showing 1 changed file with 1 addition and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -1306,6 +1306,7 @@ public void closeComplete(Object ctx) {
public void closeFailed(ManagedLedgerException exception, Object ctx) {
log.error("[{}] Failed to close managed ledger, proceeding anyway.", topic, exception);
brokerService.removeTopicFromCache(topic);
unregisterTopicPolicyListener();
closeFuture.complete(null);
}
}, null);
Expand Down

0 comments on commit 668f6d4

Please sign in to comment.