You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ja...@apache.org on 2022/08/24 20:09:01 UTC
[camel-quarkus] branch main updated: Fix potential NPE in change feed result checking
This is an automated email from the ASF dual-hosted git repository.
jamesnetherton pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
The following commit(s) were added to refs/heads/main by this push:
new 8b4070c036 Fix potential NPE in change feed result checking
8b4070c036 is described below
commit 8b4070c036608979530f03e5a68317e226dfcf5c
Author: James Netherton <ja...@gmail.com>
AuthorDate: Wed Aug 24 14:25:43 2022 +0100
Fix potential NPE in change feed result checking
---
.../azure/storage/blob/it/AzureStorageBlobResource.java | 11 +++++++++--
1 file changed, 9 insertions(+), 2 deletions(-)
diff --git a/integration-test-groups/azure/azure-storage-blob/src/main/java/org/apache/camel/quarkus/component/azure/storage/blob/it/AzureStorageBlobResource.java b/integration-test-groups/azure/azure-storage-blob/src/main/java/org/apache/camel/quarkus/component/azure/storage/blob/it/AzureStorageBlobResource.java
index bea14e5c8b..793d943051 100644
--- a/integration-test-groups/azure/azure-storage-blob/src/main/java/org/apache/camel/quarkus/component/azure/storage/blob/it/AzureStorageBlobResource.java
+++ b/integration-test-groups/azure/azure-storage-blob/src/main/java/org/apache/camel/quarkus/component/azure/storage/blob/it/AzureStorageBlobResource.java
@@ -400,9 +400,16 @@ public class AzureStorageBlobResource {
List<BlobChangefeedEvent> events = producerTemplate.requestBodyAndHeaders("direct:getChangeFeed", null, headers,
List.class);
+
+ if (events == null) {
+ return false;
+ }
+
return events.stream()
- .filter(event -> event.getEventType().equals(BlobChangefeedEventType.BLOB_CREATED))
- .anyMatch(event -> event.getData().getETag().equals(eTag));
+ .filter(event -> event.getEventType() != null
+ && event.getEventType().equals(BlobChangefeedEventType.BLOB_CREATED))
+ .anyMatch(event -> event.getData() != null && event.getData().getETag() != null
+ && event.getData().getETag().equals(eTag));
}
@Path("/consumed/blobs")