docs: @Override
      public void open() throws IOException {
          super.open();
          this.executor = Executors.newSingleThreadScheduledExecutor();
          try {
              new RedisSocketReplicatorRetrier().retry(this);
          } finally {
              doClose();
              doCloseListener(this);
              terminateQuietly(executor, configuration.getConnectionTimeout(), MILLISECONDS);
          }
      }