codingwangqi commented on a change in pull request #1747: Set ConnectionExpired
Listener to MetadataClientDriver in AR
URL: https://github.com/apache/bookkeeper/pull/1747#discussion_r224678408
##########
File path:
bookkeeper-server/src/main/java/org/apache/bookkeeper/replication/AutoRecoveryMain.java
##########
@@ -91,6 +92,11 @@ public AutoRecoveryMain(ServerConfiguration conf,
StatsLogger statsLogger)
CompatibilityException {
this.conf = conf;
this.bkc = Auditor.createBookKeeperClient(conf);
+ MetadataClientDriver metadataClientDriver =
bkc.getMetadataClientDriver();
+ metadataClientDriver.setConnectionExpiredListener(() -> {
Review comment:
@sijie thank you for pointing this out. yes, I think session expires is an
implementation specific behavior, I will incorporate your proposal into #1701
once this change is merged.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
