This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch azure-upload
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 4ca440223380017f0e6a471ebb6b5f8f7c68e961
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Tue Apr 30 15:10:14 2024 +0200
CAMEL-20727: camel-azure - Data lake upload should not read content into
memory
---
.../camel/component/azure/storage/datalake/DataLakeProducer.java | 4 +---
.../azure/storage/datalake/operations/DataLakeFileOperations.java | 6 +++---
2 files changed, 4 insertions(+), 6 deletions(-)
diff --git
a/components/camel-azure/camel-azure-storage-datalake/src/main/java/org/apache/camel/component/azure/storage/datalake/DataLakeProducer.java
b/components/camel-azure/camel-azure-storage-datalake/src/main/java/org/apache/camel/component/azure/storage/datalake/DataLakeProducer.java
index 8860252b9d4..ab0af314c6e 100644
---
a/components/camel-azure/camel-azure-storage-datalake/src/main/java/org/apache/camel/component/azure/storage/datalake/DataLakeProducer.java
+++
b/components/camel-azure/camel-azure-storage-datalake/src/main/java/org/apache/camel/component/azure/storage/datalake/DataLakeProducer.java
@@ -16,8 +16,6 @@
*/
package org.apache.camel.component.azure.storage.datalake;
-import java.io.IOException;
-
import org.apache.camel.Endpoint;
import org.apache.camel.Exchange;
import
org.apache.camel.component.azure.storage.datalake.client.DataLakeDirectoryClientWrapper;
@@ -50,7 +48,7 @@ public class DataLakeProducer extends DefaultProducer {
}
@Override
- public void process(Exchange exchange) throws IllegalArgumentException,
IOException {
+ public void process(Exchange exchange) throws Exception {
DataLakeOperationsDefinition operation = determineOperation(exchange);
switch (operation) {
case listFileSystem:
diff --git
a/components/camel-azure/camel-azure-storage-datalake/src/main/java/org/apache/camel/component/azure/storage/datalake/operations/DataLakeFileOperations.java
b/components/camel-azure/camel-azure-storage-datalake/src/main/java/org/apache/camel/component/azure/storage/datalake/operations/DataLakeFileOperations.java
index dcdd6fa4938..72ab8856a89 100644
---
a/components/camel-azure/camel-azure-storage-datalake/src/main/java/org/apache/camel/component/azure/storage/datalake/operations/DataLakeFileOperations.java
+++
b/components/camel-azure/camel-azure-storage-datalake/src/main/java/org/apache/camel/component/azure/storage/datalake/operations/DataLakeFileOperations.java
@@ -203,15 +203,15 @@ public class DataLakeFileOperations {
return new DataLakeOperationResponse(true);
}
- public DataLakeOperationResponse upload(final Exchange exchange) throws
IOException {
+ public DataLakeOperationResponse upload(final Exchange exchange) throws
Exception {
final FileCommonRequestOptions commonRequestOptions =
getCommonRequestOptions(exchange);
final ParallelTransferOptions transferOptions =
configurationProxy.getParallelTransferOptions(exchange);
- final FileStreamAndLength fileStreamAndLength =
FileStreamAndLength.createFileStreamAndLengthFromExchangeBody(exchange);
+ final InputStream is =
exchange.getMessage().getMandatoryBody(InputStream.class);
final String permission = configurationProxy.getPermission(exchange);
final String umask = configurationProxy.getUmask(exchange);
final FileParallelUploadOptions uploadOptions
- = new
FileParallelUploadOptions(fileStreamAndLength.getInputStream())
+ = new FileParallelUploadOptions(is)
.setHeaders(commonRequestOptions.getPathHttpHeaders()).setParallelTransferOptions(transferOptions)
.setMetadata(commonRequestOptions.getMetadata()).setPermissions(permission)
.setRequestConditions(commonRequestOptions.getRequestConditions())
