You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ji...@apache.org on 2026/01/09 08:52:44 UTC
(camel-quarkus) 12/41: Fixed qdrant
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
commit 70134b7753a3248c584e54a3e4e619f556eca1cc
Author: Jiri Ondrusek <on...@gmail.com>
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 | 4 ++--
3 files changed, 9 insertions(+), 5 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 ec521a03fe..3a519740fd 100644
--- a/pom.xml
+++ b/pom.xml
@@ -265,8 +265,8 @@
<oracle-debezium.container.image>mirror.gcr.io/gvenzl/oracle-free:23.9-slim-faststart</oracle-debezium.container.image>
<pinecone.container.image>ghcr.io/pinecone-io/pinecone-local:v1.0.0.rc0</pinecone.container.image>
<postgres.container.image>mirror.gcr.io/postgres:17.5</postgres.container.image>
- <postgres-debezium.container.image>quay.io/debezium/postgres:17-alpine</postgres-debezium.container.image>
- <qdrant.container.image>mirror.gcr.io/qdrant/qdrant:v1.15.5-unprivileged</qdrant.container.image>
+ <postgres-debezium.container.image>mirror.gcr.io/debezium/postgres:17-alpine</postgres-debezium.container.image>
+ <qdrant.container.image>mirror.gcr.io/qdrant/qdrant:v1.16.0-unprivileged</qdrant.container.image>
<rabbitmq.container.image>mirror.gcr.io/rabbitmq:4.1.2-management-alpine</rabbitmq.container.image>
<redis.container.image>mirror.gcr.io/redis:7.4.0-alpine</redis.container.image>
<servicebus-emulator.container.image>mcr.microsoft.com/azure-messaging/servicebus-emulator:latest</servicebus-emulator.container.image>