docs: private void registerListeners() {
      protocol.registerAppendHandler(this::append);
      protocol.registerBackupHandler(this::backup);
      protocol.registerConsumeHandler(this::consume);
      protocol.registerResetConsumer(this::reset, threadContext);
    }