This is an automated email from the ASF dual-hosted git repository. github-bot pushed a commit to branch camel-main in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit e39deb5e9f35d0ece52dcf359317bbf3885f0b3f 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 72e1a573ed..2949dbb967 100644 --- a/pom.xml +++ b/pom.xml @@ -266,7 +266,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>
