This is an automated email from the ASF dual-hosted git repository.
Croway pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-spring-boot-examples.git
The following commit(s) were added to refs/heads/main by this push:
new 5c0d29e7 CSB-8936: Add support for finding blobs by index tags
5c0d29e7 is described below
commit 5c0d29e7830cc352786749503eb7cfcca65ed22c
Author: Thomas <[email protected]>
AuthorDate: Tue Oct 6 12:15:57 2026 +0200
CSB-8936: Add support for finding blobs by index tags
- Add findBlobsByTags integration test
Co-Authored-By: Claude Opus 4.6 <[email protected]>
---
.../src/test/java/camel/sample/BlobTagsTest.java | 17 +++++++++++++++++
1 file changed, 17 insertions(+)
diff --git
a/azure/camel-example-spring-boot-azure-storage-blob/src/test/java/camel/sample/BlobTagsTest.java
b/azure/camel-example-spring-boot-azure-storage-blob/src/test/java/camel/sample/BlobTagsTest.java
index 4a814249..66c1fff6 100644
---
a/azure/camel-example-spring-boot-azure-storage-blob/src/test/java/camel/sample/BlobTagsTest.java
+++
b/azure/camel-example-spring-boot-azure-storage-blob/src/test/java/camel/sample/BlobTagsTest.java
@@ -136,4 +136,21 @@ public class BlobTagsTest {
assertEquals("document", retrieved.get("category"));
assertEquals("high", retrieved.get("priority"));
}
+
+ @Test
+ void testFindBlobsByTags() {
+ uploadTestBlob();
+
+ Map<String, String> tags = Map.of("Environment", "Production");
+ template.send("direct:setBlobTags", exchange -> {
+ exchange.getIn().setHeader(BlobConstants.BLOB_NAME, BLOB_NAME);
+ exchange.getIn().setHeader(BlobConstants.BLOB_TAGS, tags);
+ });
+
+ Exchange result = template.send("direct:findBlobsByTags", exchange -> {
+ exchange.getIn().setHeader(BlobConstants.BLOB_TAG_FILTER,
"\"Environment\" = 'Production'");
+ });
+ assertNull(result.getException(), "findBlobsByTags should succeed: " +
result.getException());
+ assertNotNull(result.getMessage().getBody(), "Should return results");
+ }
}