Skip to content

Commit b999868

Browse files
committed
Fixed S3 integration tests bucket names
1 parent e242ce3 commit b999868

File tree

1 file changed

+8
-8
lines changed
  • integration-tests/amazon-services/src/main/java/io/quarkus/it/amazon/s3

1 file changed

+8
-8
lines changed

integration-tests/amazon-services/src/main/java/io/quarkus/it/amazon/s3/S3Resource.java

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -39,13 +39,13 @@ public class S3Resource {
3939
@Path("async")
4040
@Produces(TEXT_PLAIN)
4141
public CompletionStage<String> testAsyncS3() {
42-
LOG.info("Testing Async S3 client with bucket: " + SYNC_BUCKET);
42+
LOG.info("Testing Async S3 client with bucket: " + ASYNC_BUCKET);
4343
String keyValue = UUID.randomUUID().toString();
4444

45-
return S3Utils.createBucketAsync(s3AsyncClient, SYNC_BUCKET)
46-
.thenCompose(bucket -> s3AsyncClient.putObject(S3Utils.createPutRequest(SYNC_BUCKET, keyValue),
45+
return S3Utils.createBucketAsync(s3AsyncClient, ASYNC_BUCKET)
46+
.thenCompose(bucket -> s3AsyncClient.putObject(S3Utils.createPutRequest(ASYNC_BUCKET, keyValue),
4747
AsyncRequestBody.fromString(SAMPLE_S3_OBJECT)))
48-
.thenCompose(resp -> s3AsyncClient.getObject(S3Utils.createGetRequest(SYNC_BUCKET, keyValue),
48+
.thenCompose(resp -> s3AsyncClient.getObject(S3Utils.createGetRequest(ASYNC_BUCKET, keyValue),
4949
AsyncResponseTransformer.toBytes()))
5050
.thenApply(resp -> metadata(resp.response()) + "+" + resp.asUtf8String())
5151
.exceptionally(th -> {
@@ -58,18 +58,18 @@ public CompletionStage<String> testAsyncS3() {
5858
@Path("blocking")
5959
@Produces(TEXT_PLAIN)
6060
public String testBlockingS3() {
61-
LOG.info("Testing S3 Blocking client with bucket: " + ASYNC_BUCKET);
61+
LOG.info("Testing S3 Blocking client with bucket: " + SYNC_BUCKET);
6262

6363
String keyValue = UUID.randomUUID().toString();
6464
String result = null;
6565

6666
try {
67-
if (S3Utils.createBucket(s3Client, ASYNC_BUCKET)) {
68-
if (s3Client.putObject(S3Utils.createPutRequest(ASYNC_BUCKET, keyValue),
67+
if (S3Utils.createBucket(s3Client, SYNC_BUCKET)) {
68+
if (s3Client.putObject(S3Utils.createPutRequest(SYNC_BUCKET, keyValue),
6969
RequestBody.fromString(SAMPLE_S3_OBJECT)) != null) {
7070
ByteArrayOutputStream baos = new ByteArrayOutputStream();
7171

72-
GetObjectResponse object = s3Client.getObject(S3Utils.createGetRequest(ASYNC_BUCKET, keyValue),
72+
GetObjectResponse object = s3Client.getObject(S3Utils.createGetRequest(SYNC_BUCKET, keyValue),
7373
ResponseTransformer.toOutputStream(baos));
7474

7575
if (object != null) {

0 commit comments

Comments
 (0)