Skip to content
This repository was archived by the owner on Nov 10, 2025. It is now read-only.

Commit 29235e6

Browse files
committed
Fix S3MessageHandler for key from file
1 parent 4e2ed1a commit 29235e6

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

src/main/java/org/springframework/integration/aws/outbound/S3MessageHandler.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -266,6 +266,9 @@ private Transfer upload(Message<?> requestMessage, @Nullable TransferListener tr
266266
if (this.keyExpression != null) {
267267
key = this.keyExpression.getValue(this.evaluationContext, requestMessage, String.class);
268268
}
269+
else if (payload instanceof File fileToUpload) {
270+
key = fileToUpload.getName();
271+
}
269272

270273
if (payload instanceof File fileToUpload && fileToUpload.isDirectory()) {
271274
UploadDirectoryRequest.Builder uploadDirectoryRequest =
@@ -302,9 +305,6 @@ private Transfer upload(Message<?> requestMessage, @Nullable TransferListener tr
302305
requestBody = AsyncRequestBody.fromBytes(body);
303306
}
304307
else if (payload instanceof File fileToUpload) {
305-
if (key == null) {
306-
putObjectRequestBuilder.key(fileToUpload.getName());
307-
}
308308
if (putObjectRequest.contentMD5() == null) {
309309
String contentMd5 = Md5Utils.md5AsBase64(fileToUpload);
310310
putObjectRequestBuilder.contentMD5(contentMd5);

0 commit comments

Comments
 (0)