diff --git a/src/main/java/com/knowledge/base/infrastructure/south/minio/MinioOSGatewayImpl.java b/src/main/java/com/knowledge/base/infrastructure/south/minio/MinioOSGatewayImpl.java index 7cb269e..75b1f48 100644 --- a/src/main/java/com/knowledge/base/infrastructure/south/minio/MinioOSGatewayImpl.java +++ b/src/main/java/com/knowledge/base/infrastructure/south/minio/MinioOSGatewayImpl.java @@ -52,11 +52,11 @@ public class MinioOSGatewayImpl implements ObjectStorageGateway { @Override public void ensureBucketExists(String bucket) throws Exception { - boolean exists = minioClient.bucketExists( + boolean exists = localMinioClient.bucketExists( BucketExistsArgs.builder().bucket(bucket).build() ); if (!exists) { - minioClient.makeBucket(MakeBucketArgs.builder().bucket(bucket).build()); + localMinioClient.makeBucket(MakeBucketArgs.builder().bucket(bucket).build()); log.info("已创建 bucket: {}", bucket); } } @@ -84,7 +84,7 @@ public class MinioOSGatewayImpl implements ObjectStorageGateway { return String.format("http://s3.wisdompulse.cn/%s/%s", bucket, objectPath); } else { // 生成预签名链接(最大 7 天) - return minioClient.getPresignedObjectUrl( + return localMinioClient.getPresignedObjectUrl( GetPresignedObjectUrlArgs.builder() .method(Method.GET) .bucket(bucket) @@ -103,7 +103,7 @@ public class MinioOSGatewayImpl implements ObjectStorageGateway { } try { - Iterable> results = minioClient.removeObjects( + Iterable> results = localMinioClient.removeObjects( RemoveObjectsArgs.builder() .bucket(bucket) .objects(objectPaths.stream()