This is an automated email from the ASF dual-hosted git repository. orpiske pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git
commit 7d464d4903e42ed965e6acf35236ea29c187deb1 Author: Otavio Rodolfo Piske <[email protected]> AuthorDate: Tue Mar 8 10:37:09 2022 +0100 CAMEL-15520: fixed deprecations in camel-azure-storage-queue --- .../org/apache/camel/component/azure/storage/queue/QueueConsumer.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/components/camel-azure/camel-azure-storage-queue/src/main/java/org/apache/camel/component/azure/storage/queue/QueueConsumer.java b/components/camel-azure/camel-azure-storage-queue/src/main/java/org/apache/camel/component/azure/storage/queue/QueueConsumer.java index 7d2d02b..d48ab82 100644 --- a/components/camel-azure/camel-azure-storage-queue/src/main/java/org/apache/camel/component/azure/storage/queue/QueueConsumer.java +++ b/components/camel-azure/camel-azure-storage-queue/src/main/java/org/apache/camel/component/azure/storage/queue/QueueConsumer.java @@ -22,6 +22,7 @@ import java.util.List; import java.util.Queue; import java.util.stream.Collectors; +import com.azure.core.util.BinaryData; import com.azure.storage.queue.QueueServiceClient; import com.azure.storage.queue.models.QueueMessageItem; import com.azure.storage.queue.models.QueueStorageException; @@ -157,7 +158,8 @@ public class QueueConsumer extends ScheduledBatchPollingConsumer { final Exchange exchange = createExchange(true); final Message message = exchange.getIn(); - message.setBody(messageItem.getMessageText()); + BinaryData data = messageItem.getBody(); + message.setBody(data == null ? null : data.toString()); message.setHeaders(QueueExchangeHeaders.createQueueExchangeHeadersFromQueueMessageItem(messageItem).toMap()); return exchange;
