This is an automated email from the ASF dual-hosted git repository.
jiriondrusek pushed a commit to branch camel-main
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
The following commit(s) were added to refs/heads/camel-main by this push:
new 2f7ede07f6 Fixed qdrant
2f7ede07f6 is described below
commit 2f7ede07f6a618bcb251e65cdab3aac6fa2186a3
Author: Jiri Ondrusek <[email protected]>
AuthorDate: Mon Nov 24 15:03:52 2025 +0100
Fixed qdrant
---
.../apache/camel/quarkus/component/qdrant/it/QdrantResource.java | 8 ++++++--
.../org/apache/camel/quarkus/component/qdrant/it/QdrantTest.java | 2 +-
pom.xml | 2 +-
3 files changed, 8 insertions(+), 4 deletions(-)
diff --git
a/integration-tests/qdrant/src/main/java/org/apache/camel/quarkus/component/qdrant/it/QdrantResource.java
b/integration-tests/qdrant/src/main/java/org/apache/camel/quarkus/component/qdrant/it/QdrantResource.java
index c2e7d92fef..6d08b06e9f 100644
---
a/integration-tests/qdrant/src/main/java/org/apache/camel/quarkus/component/qdrant/it/QdrantResource.java
+++
b/integration-tests/qdrant/src/main/java/org/apache/camel/quarkus/component/qdrant/it/QdrantResource.java
@@ -21,11 +21,11 @@ import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
-import io.qdrant.client.ConditionFactory;
import io.qdrant.client.PointIdFactory;
import io.qdrant.client.ValueFactory;
import io.qdrant.client.VectorsFactory;
import io.qdrant.client.grpc.Collections;
+import io.qdrant.client.grpc.Common;
import io.qdrant.client.grpc.Points;
import jakarta.enterprise.context.ApplicationScoped;
import jakarta.inject.Inject;
@@ -41,6 +41,8 @@ import org.apache.camel.FluentProducerTemplate;
import org.apache.camel.component.qdrant.QdrantAction;
import org.apache.camel.component.qdrant.QdrantHeaders;
+import static io.qdrant.client.ConditionFactory.matchKeyword;
+
@Path("/qdrant")
@ApplicationScoped
public class QdrantResource {
@@ -106,7 +108,9 @@ public class QdrantResource {
Exchange exchange = producer.to("qdrant:testCollection")
.withHeader(QdrantHeaders.ACTION, QdrantAction.DELETE)
- .withBody(ConditionFactory.matchKeyword("foo", "hello"))
+ .withBody(Common.Filter.newBuilder()
+ .addMust(matchKeyword("foo", "hello"))
+ .build())
.request(Exchange.class);
Object operationId =
exchange.getIn().getHeader(QdrantHeaders.OPERATION_ID);
diff --git
a/integration-tests/qdrant/src/test/java/org/apache/camel/quarkus/component/qdrant/it/QdrantTest.java
b/integration-tests/qdrant/src/test/java/org/apache/camel/quarkus/component/qdrant/it/QdrantTest.java
index 093d3b395e..fc3a91958a 100644
---
a/integration-tests/qdrant/src/test/java/org/apache/camel/quarkus/component/qdrant/it/QdrantTest.java
+++
b/integration-tests/qdrant/src/test/java/org/apache/camel/quarkus/component/qdrant/it/QdrantTest.java
@@ -45,7 +45,7 @@ class QdrantTest {
RestAssured.delete("/qdrant/delete")
.then()
.statusCode(200)
- .body(is("1/Completed/2"));
+ .body(is("2/Completed/2"));
RestAssured.get("/qdrant/retrieve")
.then()
diff --git a/pom.xml b/pom.xml
index ed3e0bdddb..f1157e9d0d 100644
--- a/pom.xml
+++ b/pom.xml
@@ -263,7 +263,7 @@
<pinecone.container.image>ghcr.io/pinecone-io/pinecone-local:v0.7.0</pinecone.container.image>
<postgres.container.image>mirror.gcr.io/postgres:15.0</postgres.container.image>
<postgres-debezium.container.image>mirror.gcr.io/debezium/postgres:15-alpine</postgres-debezium.container.image>
-
<qdrant.container.image>mirror.gcr.io/qdrant/qdrant:v1.9.7-unprivileged</qdrant.container.image>
+
<qdrant.container.image>mirror.gcr.io/qdrant/qdrant:v1.16.0-unprivileged</qdrant.container.image>
<rabbitmq.container.image>mirror.gcr.io/rabbitmq:3.13.7-management-alpine</rabbitmq.container.image>
<redis.container.image>mirror.gcr.io/redis:6.2.14-alpine</redis.container.image>
<servicebus-emulator.container.image>mcr.microsoft.com/azure-messaging/servicebus-emulator:latest</servicebus-emulator.container.image>
