@Test void testCreateClient() { assertThrows(IOException.class, () -> minioClientFactoryImpl.createClient()); }
@Override @Retryable( value = {IOException.class}, maxAttempts = 10, backoff = @Backoff(delay = 1000, multiplier = 2.0)) public MinioClient createClient() throws IOException { MinioClient minioClient; try { minioClient = new MinioClient(minioEndpoint, minioAccessKey, minioSecretKey, region); } catch (InvalidEndpointException | InvalidPortException e) { throw new IllegalArgumentException(e); } LOG.debug("Connecting to Minio on '{}' ...", minioEndpoint); createBucketIfNotExists(minioClient, bucketName, region); LOG.info("Connected to Minio on '{}'", minioEndpoint); return minioClient; }
MinioClientFactoryImpl implements MinioClientFactory { @Override @Retryable( value = {IOException.class}, maxAttempts = 10, backoff = @Backoff(delay = 1000, multiplier = 2.0)) public MinioClient createClient() throws IOException { MinioClient minioClient; try { minioClient = new MinioClient(minioEndpoint, minioAccessKey, minioSecretKey, region); } catch (InvalidEndpointException | InvalidPortException e) { throw new IllegalArgumentException(e); } LOG.debug("Connecting to Minio on '{}' ...", minioEndpoint); createBucketIfNotExists(minioClient, bucketName, region); LOG.info("Connected to Minio on '{}'", minioEndpoint); return minioClient; } }
MinioClientFactoryImpl implements MinioClientFactory { @Override @Retryable( value = {IOException.class}, maxAttempts = 10, backoff = @Backoff(delay = 1000, multiplier = 2.0)) public MinioClient createClient() throws IOException { MinioClient minioClient; try { minioClient = new MinioClient(minioEndpoint, minioAccessKey, minioSecretKey, region); } catch (InvalidEndpointException | InvalidPortException e) { throw new IllegalArgumentException(e); } LOG.debug("Connecting to Minio on '{}' ...", minioEndpoint); createBucketIfNotExists(minioClient, bucketName, region); LOG.info("Connected to Minio on '{}'", minioEndpoint); return minioClient; } MinioClientFactoryImpl(
      String bucketName,
      String endpoint,
      String accessKey,
      String secretKey,
      @Nullable String region); }
MinioClientFactoryImpl implements MinioClientFactory { @Override @Retryable( value = {IOException.class}, maxAttempts = 10, backoff = @Backoff(delay = 1000, multiplier = 2.0)) public MinioClient createClient() throws IOException { MinioClient minioClient; try { minioClient = new MinioClient(minioEndpoint, minioAccessKey, minioSecretKey, region); } catch (InvalidEndpointException | InvalidPortException e) { throw new IllegalArgumentException(e); } LOG.debug("Connecting to Minio on '{}' ...", minioEndpoint); createBucketIfNotExists(minioClient, bucketName, region); LOG.info("Connected to Minio on '{}'", minioEndpoint); return minioClient; } MinioClientFactoryImpl(
      String bucketName,
      String endpoint,
      String accessKey,
      String secretKey,
      @Nullable String region); @Override @Retryable( value = {IOException.class}, maxAttempts = 10, backoff = @Backoff(delay = 1000, multiplier = 2.0)) MinioClient createClient(); }
MinioClientFactoryImpl implements MinioClientFactory { @Override @Retryable( value = {IOException.class}, maxAttempts = 10, backoff = @Backoff(delay = 1000, multiplier = 2.0)) public MinioClient createClient() throws IOException { MinioClient minioClient; try { minioClient = new MinioClient(minioEndpoint, minioAccessKey, minioSecretKey, region); } catch (InvalidEndpointException | InvalidPortException e) { throw new IllegalArgumentException(e); } LOG.debug("Connecting to Minio on '{}' ...", minioEndpoint); createBucketIfNotExists(minioClient, bucketName, region); LOG.info("Connected to Minio on '{}'", minioEndpoint); return minioClient; } MinioClientFactoryImpl(
      String bucketName,
      String endpoint,
      String accessKey,
      String secretKey,
      @Nullable String region); @Override @Retryable( value = {IOException.class}, maxAttempts = 10, backoff = @Backoff(delay = 1000, multiplier = 2.0)) MinioClient createClient();  }