This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new d40aac2b743f Remove usage of deprecated methods in qdrant (#20381)
d40aac2b743f is described below
commit d40aac2b743febcc712b213c902066e6527e54b9
Author: Aurélien Pupier <[email protected]>
AuthorDate: Mon Dec 15 07:31:51 2025 +0100
Remove usage of deprecated methods in qdrant (#20381)
* CAMEL-22766 - Fix Qdrant Similarity Search
Signed-off-by: Aurélien Pupier <[email protected]>
* Remove usage of deprecated methods in Qdrant component
Signed-off-by: Aurélien Pupier <[email protected]>
---------
Signed-off-by: Aurélien Pupier <[email protected]>
---
.../apache/camel/catalog/components/qdrant.json | 20 ++++++------
.../org/apache/camel/component/qdrant/qdrant.json | 20 ++++++------
.../camel/component/qdrant/QdrantEndpoint.java | 2 +-
.../camel/component/qdrant/QdrantProducer.java | 38 +++++++++++-----------
.../QdrantEmbeddingsDataTypeTransformer.java | 4 +--
.../camel/component/qdrant/QdrantTestSupport.java | 4 +--
6 files changed, 44 insertions(+), 44 deletions(-)
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/qdrant.json
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/qdrant.json
index 6d079730b8a7..0f5d712d637b 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/qdrant.json
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/qdrant.json
@@ -36,16 +36,16 @@
"tls": { "index": 9, "kind": "property", "displayName": "Tls", "group":
"security", "label": "security", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.qdrant.QdrantConfiguration", "configurationField":
"configuration", "description": "Whether the client uses Transport Layer
Security (TLS) to secure communications" }
},
"headers": {
- "CamelQdrantAction": { "index": 0, "kind": "header", "displayName": "",
"group": "producer", "label": "", "required": false, "javaType": "String",
"enum": [ "CREATE_COLLECTION", "DELETE_COLLECTION", "UPSERT", "RETRIEVE",
"DELETE", "COLLECTION_INFO", "SIMILARITY_SEARCH" ], "deprecated": false,
"deprecationNote": "", "autowired": false, "secret": false, "description": "The
action to be performed.", "constantName":
"org.apache.camel.component.qdrant.Qdrant$Headers#ACTION" },
- "CamelQdrantPointsPayloadSelector": { "index": 1, "kind": "header",
"displayName": "", "group": "producer", "label": "", "required": false,
"javaType": "io.qdrant.client.grpc.Points$WithPayloadSelector", "deprecated":
false, "deprecationNote": "", "autowired": false, "secret": false,
"description": "Payload Selector.", "constantName":
"org.apache.camel.component.qdrant.Qdrant$Headers#PAYLOAD_SELECTOR" },
- "CamelQdrantOperationID": { "index": 2, "kind": "header", "displayName":
"", "group": "producer", "label": "", "required": false, "javaType": "long",
"deprecated": false, "deprecationNote": "", "autowired": false, "secret":
false, "description": "Operation ID.", "constantName":
"org.apache.camel.component.qdrant.Qdrant$Headers#OPERATION_ID" },
- "CamelQdrantOperationStatus": { "index": 3, "kind": "header",
"displayName": "", "group": "producer", "label": "", "required": false,
"javaType": "String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "Operation Status.", "constantName":
"org.apache.camel.component.qdrant.Qdrant$Headers#OPERATION_STATUS" },
- "CamelQdrantOperationStatusValue": { "index": 4, "kind": "header",
"displayName": "", "group": "producer", "label": "", "required": false,
"javaType": "int", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "Operation Status Value.",
"constantName":
"org.apache.camel.component.qdrant.Qdrant$Headers#OPERATION_STATUS_VALUE" },
- "CamelQdrantReadConsistency": { "index": 5, "kind": "header",
"displayName": "", "group": "producer", "label": "", "required": false,
"javaType": "io.qdrant.client.grpc.Points$ReadConsistency", "deprecated":
false, "deprecationNote": "", "autowired": false, "secret": false,
"description": "Read Consistency.", "constantName":
"org.apache.camel.component.qdrant.Qdrant$Headers#READ_CONSISTENCY" },
- "CamelQdrantWithPayload": { "index": 6, "kind": "header", "displayName":
"", "group": "producer", "label": "", "required": false, "javaType": "boolean",
"deprecated": false, "deprecationNote": "", "autowired": false, "secret":
false, "defaultValue": "true", "description": "Include Payload.",
"constantName":
"org.apache.camel.component.qdrant.Qdrant$Headers#INCLUDE_PAYLOAD" },
- "CamelQdrantWithVectors": { "index": 7, "kind": "header", "displayName":
"", "group": "producer", "label": "", "required": false, "javaType": "boolean",
"deprecated": false, "deprecationNote": "", "autowired": false, "secret":
false, "defaultValue": "false", "description": "Include Vectors.",
"constantName":
"org.apache.camel.component.qdrant.Qdrant$Headers#INCLUDE_VECTORS" },
- "CamelQdrantSize": { "index": 8, "kind": "header", "displayName": "",
"group": "producer", "label": "", "required": false, "javaType": "int",
"deprecated": false, "deprecationNote": "", "autowired": false, "secret":
false, "description": "The number of elements.", "constantName":
"org.apache.camel.component.qdrant.Qdrant$Headers#SIZE" },
- "CamelQdrantPointId": { "index": 9, "kind": "header", "displayName": "",
"group": "producer", "label": "", "required": false, "javaType": "int",
"deprecated": false, "deprecationNote": "", "autowired": false, "secret":
false, "description": "The point id to use for operation.", "constantName":
"org.apache.camel.component.qdrant.Qdrant$Headers#POINT_ID" }
+ "CamelQdrantAction": { "index": 0, "kind": "header", "displayName": "",
"group": "producer", "label": "", "required": false, "javaType": "String",
"enum": [ "CREATE_COLLECTION", "DELETE_COLLECTION", "UPSERT", "RETRIEVE",
"DELETE", "COLLECTION_INFO", "SIMILARITY_SEARCH" ], "deprecated": false,
"deprecationNote": "", "autowired": false, "secret": false, "description": "The
action to be performed.", "constantName":
"org.apache.camel.component.qdrant.QdrantHeaders#ACTION" },
+ "CamelQdrantPointsPayloadSelector": { "index": 1, "kind": "header",
"displayName": "", "group": "producer", "label": "", "required": false,
"javaType": "io.qdrant.client.grpc.Points$WithPayloadSelector", "deprecated":
false, "deprecationNote": "", "autowired": false, "secret": false,
"description": "Payload Selector.", "constantName":
"org.apache.camel.component.qdrant.QdrantHeaders#PAYLOAD_SELECTOR" },
+ "CamelQdrantOperationID": { "index": 2, "kind": "header", "displayName":
"", "group": "producer", "label": "", "required": false, "javaType": "long",
"deprecated": false, "deprecationNote": "", "autowired": false, "secret":
false, "description": "Operation ID.", "constantName":
"org.apache.camel.component.qdrant.QdrantHeaders#OPERATION_ID" },
+ "CamelQdrantOperationStatus": { "index": 3, "kind": "header",
"displayName": "", "group": "producer", "label": "", "required": false,
"javaType": "String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "Operation Status.", "constantName":
"org.apache.camel.component.qdrant.QdrantHeaders#OPERATION_STATUS" },
+ "CamelQdrantOperationStatusValue": { "index": 4, "kind": "header",
"displayName": "", "group": "producer", "label": "", "required": false,
"javaType": "int", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "Operation Status Value.",
"constantName":
"org.apache.camel.component.qdrant.QdrantHeaders#OPERATION_STATUS_VALUE" },
+ "CamelQdrantReadConsistency": { "index": 5, "kind": "header",
"displayName": "", "group": "producer", "label": "", "required": false,
"javaType": "io.qdrant.client.grpc.Points$ReadConsistency", "deprecated":
false, "deprecationNote": "", "autowired": false, "secret": false,
"description": "Read Consistency.", "constantName":
"org.apache.camel.component.qdrant.QdrantHeaders#READ_CONSISTENCY" },
+ "CamelQdrantWithPayload": { "index": 6, "kind": "header", "displayName":
"", "group": "producer", "label": "", "required": false, "javaType": "boolean",
"deprecated": false, "deprecationNote": "", "autowired": false, "secret":
false, "defaultValue": "true", "description": "Include Payload.",
"constantName":
"org.apache.camel.component.qdrant.QdrantHeaders#INCLUDE_PAYLOAD" },
+ "CamelQdrantWithVectors": { "index": 7, "kind": "header", "displayName":
"", "group": "producer", "label": "", "required": false, "javaType": "boolean",
"deprecated": false, "deprecationNote": "", "autowired": false, "secret":
false, "defaultValue": "false", "description": "Include Vectors.",
"constantName":
"org.apache.camel.component.qdrant.QdrantHeaders#INCLUDE_VECTORS" },
+ "CamelQdrantSize": { "index": 8, "kind": "header", "displayName": "",
"group": "producer", "label": "", "required": false, "javaType": "int",
"deprecated": false, "deprecationNote": "", "autowired": false, "secret":
false, "description": "The number of elements.", "constantName":
"org.apache.camel.component.qdrant.QdrantHeaders#SIZE" },
+ "CamelQdrantPointId": { "index": 9, "kind": "header", "displayName": "",
"group": "producer", "label": "", "required": false, "javaType": "int",
"deprecated": false, "deprecationNote": "", "autowired": false, "secret":
false, "description": "The point id to use for operation.", "constantName":
"org.apache.camel.component.qdrant.QdrantHeaders#POINT_ID" }
},
"properties": {
"collection": { "index": 0, "kind": "path", "displayName": "Collection",
"group": "producer", "label": "", "required": true, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "description": "The collection Name" },
diff --git
a/components/camel-ai/camel-qdrant/src/generated/resources/META-INF/org/apache/camel/component/qdrant/qdrant.json
b/components/camel-ai/camel-qdrant/src/generated/resources/META-INF/org/apache/camel/component/qdrant/qdrant.json
index 6d079730b8a7..0f5d712d637b 100644
---
a/components/camel-ai/camel-qdrant/src/generated/resources/META-INF/org/apache/camel/component/qdrant/qdrant.json
+++
b/components/camel-ai/camel-qdrant/src/generated/resources/META-INF/org/apache/camel/component/qdrant/qdrant.json
@@ -36,16 +36,16 @@
"tls": { "index": 9, "kind": "property", "displayName": "Tls", "group":
"security", "label": "security", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.qdrant.QdrantConfiguration", "configurationField":
"configuration", "description": "Whether the client uses Transport Layer
Security (TLS) to secure communications" }
},
"headers": {
- "CamelQdrantAction": { "index": 0, "kind": "header", "displayName": "",
"group": "producer", "label": "", "required": false, "javaType": "String",
"enum": [ "CREATE_COLLECTION", "DELETE_COLLECTION", "UPSERT", "RETRIEVE",
"DELETE", "COLLECTION_INFO", "SIMILARITY_SEARCH" ], "deprecated": false,
"deprecationNote": "", "autowired": false, "secret": false, "description": "The
action to be performed.", "constantName":
"org.apache.camel.component.qdrant.Qdrant$Headers#ACTION" },
- "CamelQdrantPointsPayloadSelector": { "index": 1, "kind": "header",
"displayName": "", "group": "producer", "label": "", "required": false,
"javaType": "io.qdrant.client.grpc.Points$WithPayloadSelector", "deprecated":
false, "deprecationNote": "", "autowired": false, "secret": false,
"description": "Payload Selector.", "constantName":
"org.apache.camel.component.qdrant.Qdrant$Headers#PAYLOAD_SELECTOR" },
- "CamelQdrantOperationID": { "index": 2, "kind": "header", "displayName":
"", "group": "producer", "label": "", "required": false, "javaType": "long",
"deprecated": false, "deprecationNote": "", "autowired": false, "secret":
false, "description": "Operation ID.", "constantName":
"org.apache.camel.component.qdrant.Qdrant$Headers#OPERATION_ID" },
- "CamelQdrantOperationStatus": { "index": 3, "kind": "header",
"displayName": "", "group": "producer", "label": "", "required": false,
"javaType": "String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "Operation Status.", "constantName":
"org.apache.camel.component.qdrant.Qdrant$Headers#OPERATION_STATUS" },
- "CamelQdrantOperationStatusValue": { "index": 4, "kind": "header",
"displayName": "", "group": "producer", "label": "", "required": false,
"javaType": "int", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "Operation Status Value.",
"constantName":
"org.apache.camel.component.qdrant.Qdrant$Headers#OPERATION_STATUS_VALUE" },
- "CamelQdrantReadConsistency": { "index": 5, "kind": "header",
"displayName": "", "group": "producer", "label": "", "required": false,
"javaType": "io.qdrant.client.grpc.Points$ReadConsistency", "deprecated":
false, "deprecationNote": "", "autowired": false, "secret": false,
"description": "Read Consistency.", "constantName":
"org.apache.camel.component.qdrant.Qdrant$Headers#READ_CONSISTENCY" },
- "CamelQdrantWithPayload": { "index": 6, "kind": "header", "displayName":
"", "group": "producer", "label": "", "required": false, "javaType": "boolean",
"deprecated": false, "deprecationNote": "", "autowired": false, "secret":
false, "defaultValue": "true", "description": "Include Payload.",
"constantName":
"org.apache.camel.component.qdrant.Qdrant$Headers#INCLUDE_PAYLOAD" },
- "CamelQdrantWithVectors": { "index": 7, "kind": "header", "displayName":
"", "group": "producer", "label": "", "required": false, "javaType": "boolean",
"deprecated": false, "deprecationNote": "", "autowired": false, "secret":
false, "defaultValue": "false", "description": "Include Vectors.",
"constantName":
"org.apache.camel.component.qdrant.Qdrant$Headers#INCLUDE_VECTORS" },
- "CamelQdrantSize": { "index": 8, "kind": "header", "displayName": "",
"group": "producer", "label": "", "required": false, "javaType": "int",
"deprecated": false, "deprecationNote": "", "autowired": false, "secret":
false, "description": "The number of elements.", "constantName":
"org.apache.camel.component.qdrant.Qdrant$Headers#SIZE" },
- "CamelQdrantPointId": { "index": 9, "kind": "header", "displayName": "",
"group": "producer", "label": "", "required": false, "javaType": "int",
"deprecated": false, "deprecationNote": "", "autowired": false, "secret":
false, "description": "The point id to use for operation.", "constantName":
"org.apache.camel.component.qdrant.Qdrant$Headers#POINT_ID" }
+ "CamelQdrantAction": { "index": 0, "kind": "header", "displayName": "",
"group": "producer", "label": "", "required": false, "javaType": "String",
"enum": [ "CREATE_COLLECTION", "DELETE_COLLECTION", "UPSERT", "RETRIEVE",
"DELETE", "COLLECTION_INFO", "SIMILARITY_SEARCH" ], "deprecated": false,
"deprecationNote": "", "autowired": false, "secret": false, "description": "The
action to be performed.", "constantName":
"org.apache.camel.component.qdrant.QdrantHeaders#ACTION" },
+ "CamelQdrantPointsPayloadSelector": { "index": 1, "kind": "header",
"displayName": "", "group": "producer", "label": "", "required": false,
"javaType": "io.qdrant.client.grpc.Points$WithPayloadSelector", "deprecated":
false, "deprecationNote": "", "autowired": false, "secret": false,
"description": "Payload Selector.", "constantName":
"org.apache.camel.component.qdrant.QdrantHeaders#PAYLOAD_SELECTOR" },
+ "CamelQdrantOperationID": { "index": 2, "kind": "header", "displayName":
"", "group": "producer", "label": "", "required": false, "javaType": "long",
"deprecated": false, "deprecationNote": "", "autowired": false, "secret":
false, "description": "Operation ID.", "constantName":
"org.apache.camel.component.qdrant.QdrantHeaders#OPERATION_ID" },
+ "CamelQdrantOperationStatus": { "index": 3, "kind": "header",
"displayName": "", "group": "producer", "label": "", "required": false,
"javaType": "String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "Operation Status.", "constantName":
"org.apache.camel.component.qdrant.QdrantHeaders#OPERATION_STATUS" },
+ "CamelQdrantOperationStatusValue": { "index": 4, "kind": "header",
"displayName": "", "group": "producer", "label": "", "required": false,
"javaType": "int", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "Operation Status Value.",
"constantName":
"org.apache.camel.component.qdrant.QdrantHeaders#OPERATION_STATUS_VALUE" },
+ "CamelQdrantReadConsistency": { "index": 5, "kind": "header",
"displayName": "", "group": "producer", "label": "", "required": false,
"javaType": "io.qdrant.client.grpc.Points$ReadConsistency", "deprecated":
false, "deprecationNote": "", "autowired": false, "secret": false,
"description": "Read Consistency.", "constantName":
"org.apache.camel.component.qdrant.QdrantHeaders#READ_CONSISTENCY" },
+ "CamelQdrantWithPayload": { "index": 6, "kind": "header", "displayName":
"", "group": "producer", "label": "", "required": false, "javaType": "boolean",
"deprecated": false, "deprecationNote": "", "autowired": false, "secret":
false, "defaultValue": "true", "description": "Include Payload.",
"constantName":
"org.apache.camel.component.qdrant.QdrantHeaders#INCLUDE_PAYLOAD" },
+ "CamelQdrantWithVectors": { "index": 7, "kind": "header", "displayName":
"", "group": "producer", "label": "", "required": false, "javaType": "boolean",
"deprecated": false, "deprecationNote": "", "autowired": false, "secret":
false, "defaultValue": "false", "description": "Include Vectors.",
"constantName":
"org.apache.camel.component.qdrant.QdrantHeaders#INCLUDE_VECTORS" },
+ "CamelQdrantSize": { "index": 8, "kind": "header", "displayName": "",
"group": "producer", "label": "", "required": false, "javaType": "int",
"deprecated": false, "deprecationNote": "", "autowired": false, "secret":
false, "description": "The number of elements.", "constantName":
"org.apache.camel.component.qdrant.QdrantHeaders#SIZE" },
+ "CamelQdrantPointId": { "index": 9, "kind": "header", "displayName": "",
"group": "producer", "label": "", "required": false, "javaType": "int",
"deprecated": false, "deprecationNote": "", "autowired": false, "secret":
false, "description": "The point id to use for operation.", "constantName":
"org.apache.camel.component.qdrant.QdrantHeaders#POINT_ID" }
},
"properties": {
"collection": { "index": 0, "kind": "path", "displayName": "Collection",
"group": "producer", "label": "", "required": true, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "description": "The collection Name" },
diff --git
a/components/camel-ai/camel-qdrant/src/main/java/org/apache/camel/component/qdrant/QdrantEndpoint.java
b/components/camel-ai/camel-qdrant/src/main/java/org/apache/camel/component/qdrant/QdrantEndpoint.java
index 593885a0feab..3b7a1b845540 100644
---
a/components/camel-ai/camel-qdrant/src/main/java/org/apache/camel/component/qdrant/QdrantEndpoint.java
+++
b/components/camel-ai/camel-qdrant/src/main/java/org/apache/camel/component/qdrant/QdrantEndpoint.java
@@ -45,7 +45,7 @@ import org.apache.camel.support.DefaultEndpoint;
Category.DATABASE,
Category.AI
},
- headersClass = Qdrant.Headers.class)
+ headersClass = QdrantHeaders.class)
public class QdrantEndpoint extends DefaultEndpoint implements
EndpointServiceLocation {
@Metadata(required = true)
diff --git
a/components/camel-ai/camel-qdrant/src/main/java/org/apache/camel/component/qdrant/QdrantProducer.java
b/components/camel-ai/camel-qdrant/src/main/java/org/apache/camel/component/qdrant/QdrantProducer.java
index 4e696643dcd2..30927c074d08 100644
---
a/components/camel-ai/camel-qdrant/src/main/java/org/apache/camel/component/qdrant/QdrantProducer.java
+++
b/components/camel-ai/camel-qdrant/src/main/java/org/apache/camel/component/qdrant/QdrantProducer.java
@@ -80,11 +80,11 @@ public class QdrantProducer extends DefaultAsyncProducer {
@Override
public boolean process(Exchange exchange, AsyncCallback callback) {
final Message in = exchange.getMessage();
- final QdrantAction action = in.getHeader(Qdrant.Headers.ACTION,
QdrantAction.class);
+ final QdrantAction action = in.getHeader(QdrantHeaders.ACTION,
QdrantAction.class);
try {
if (action == null) {
- throw new NoSuchHeaderException("The action is a required
header", exchange, Qdrant.Headers.ACTION);
+ throw new NoSuchHeaderException("The action is a required
header", exchange, QdrantHeaders.ACTION);
}
return switch (action) {
@@ -130,9 +130,9 @@ public class QdrantProducer extends DefaultAsyncProducer {
if (t != null) {
exchange.setException(new
QdrantActionException(QdrantAction.UPSERT, t));
} else {
- in.setHeader(Qdrant.Headers.OPERATION_ID,
r.getOperationId());
- in.setHeader(Qdrant.Headers.OPERATION_STATUS,
r.getStatus().name());
- in.setHeader(Qdrant.Headers.OPERATION_STATUS_VALUE,
r.getStatus().getNumber());
+ in.setHeader(QdrantHeaders.OPERATION_ID,
r.getOperationId());
+ in.setHeader(QdrantHeaders.OPERATION_STATUS,
r.getStatus().name());
+ in.setHeader(QdrantHeaders.OPERATION_STATUS_VALUE,
r.getStatus().getNumber());
}
callback.done(false);
@@ -152,22 +152,22 @@ public class QdrantProducer extends DefaultAsyncProducer {
collection,
ids,
WithPayloadSelectorFactory.enable(in.getHeader(
- Qdrant.Headers.INCLUDE_PAYLOAD,
- Qdrant.Headers.DEFAULT_INCLUDE_PAYLOAD,
+ QdrantHeaders.INCLUDE_PAYLOAD,
+ QdrantHeaders.DEFAULT_INCLUDE_PAYLOAD,
boolean.class)),
WithVectorsSelectorFactory.enable(in.getHeader(
- Qdrant.Headers.INCLUDE_VECTORS,
- Qdrant.Headers.DEFAULT_INCLUDE_VECTORS,
+ QdrantHeaders.INCLUDE_VECTORS,
+ QdrantHeaders.DEFAULT_INCLUDE_VECTORS,
boolean.class)),
in.getHeader(
- Qdrant.Headers.READ_CONSISTENCY,
+ QdrantHeaders.READ_CONSISTENCY,
Points.ReadConsistency.class)),
(r, t) -> {
if (t != null) {
exchange.setException(new
QdrantActionException(QdrantAction.RETRIEVE, t));
} else {
in.setBody(new ArrayList<>(r));
- in.setHeader(Qdrant.Headers.SIZE, r.size());
+ in.setHeader(QdrantHeaders.SIZE, r.size());
}
callback.done(false);
@@ -213,9 +213,9 @@ public class QdrantProducer extends DefaultAsyncProducer {
if (t != null) {
exchange.setException(new
QdrantActionException(QdrantAction.DELETE, t));
} else {
- in.setHeader(Qdrant.Headers.OPERATION_ID,
r.getOperationId());
- in.setHeader(Qdrant.Headers.OPERATION_STATUS,
r.getStatus().name());
- in.setHeader(Qdrant.Headers.OPERATION_STATUS_VALUE,
r.getStatus().getNumber());
+ in.setHeader(QdrantHeaders.OPERATION_ID,
r.getOperationId());
+ in.setHeader(QdrantHeaders.OPERATION_STATUS,
r.getStatus().name());
+ in.setHeader(QdrantHeaders.OPERATION_STATUS_VALUE,
r.getStatus().getNumber());
}
callback.done(false);
@@ -282,12 +282,12 @@ public class QdrantProducer extends DefaultAsyncProducer {
.setQuery(nearest(vectors))
.setLimit(maxResults)
.setWithVectors(WithVectorsSelectorFactory.enable(in.getHeader(
- Qdrant.Headers.INCLUDE_VECTORS,
- Qdrant.Headers.DEFAULT_INCLUDE_VECTORS,
+ QdrantHeaders.INCLUDE_VECTORS,
+ QdrantHeaders.DEFAULT_INCLUDE_VECTORS,
boolean.class)))
.setWithPayload(enable(in.getHeader(
- Qdrant.Headers.INCLUDE_PAYLOAD,
- Qdrant.Headers.DEFAULT_INCLUDE_PAYLOAD,
+ QdrantHeaders.INCLUDE_PAYLOAD,
+ QdrantHeaders.DEFAULT_INCLUDE_PAYLOAD,
boolean.class)));
if (filter != null) {
@@ -301,7 +301,7 @@ public class QdrantProducer extends DefaultAsyncProducer {
exchange.setException(new
QdrantActionException(QdrantAction.SIMILARITY_SEARCH, t));
} else {
in.setBody(new ArrayList<>(r));
- in.setHeader(Qdrant.Headers.SIZE, r.size());
+ in.setHeader(QdrantHeaders.SIZE, r.size());
}
callback.done(false);
diff --git
a/components/camel-ai/camel-qdrant/src/main/java/org/apache/camel/component/qdrant/transform/QdrantEmbeddingsDataTypeTransformer.java
b/components/camel-ai/camel-qdrant/src/main/java/org/apache/camel/component/qdrant/transform/QdrantEmbeddingsDataTypeTransformer.java
index 058c24b94e2f..3046fe09238e 100644
---
a/components/camel-ai/camel-qdrant/src/main/java/org/apache/camel/component/qdrant/transform/QdrantEmbeddingsDataTypeTransformer.java
+++
b/components/camel-ai/camel-qdrant/src/main/java/org/apache/camel/component/qdrant/transform/QdrantEmbeddingsDataTypeTransformer.java
@@ -28,7 +28,7 @@ import io.qdrant.client.grpc.Common;
import io.qdrant.client.grpc.Points;
import org.apache.camel.Message;
import org.apache.camel.ai.CamelLangchain4jAttributes;
-import org.apache.camel.component.qdrant.Qdrant;
+import org.apache.camel.component.qdrant.QdrantHeaders;
import org.apache.camel.spi.DataType;
import org.apache.camel.spi.DataTypeTransformer;
import org.apache.camel.spi.Transformer;
@@ -45,7 +45,7 @@ public class QdrantEmbeddingsDataTypeTransformer extends
Transformer {
Embedding embedding =
message.getHeader(CamelLangchain4jAttributes.CAMEL_LANGCHAIN4J_EMBEDDING_VECTOR,
Embedding.class);
TextSegment text = message.getBody(TextSegment.class);
Common.PointId id
- = message.getHeader(Qdrant.Headers.POINT_ID, () ->
PointIdFactory.id(UUID.randomUUID()), Common.PointId.class);
+ = message.getHeader(QdrantHeaders.POINT_ID, () ->
PointIdFactory.id(UUID.randomUUID()), Common.PointId.class);
var builder = Points.PointStruct.newBuilder();
builder.setId(id);
diff --git
a/components/camel-ai/camel-qdrant/src/test/java/org/apache/camel/component/qdrant/QdrantTestSupport.java
b/components/camel-ai/camel-qdrant/src/test/java/org/apache/camel/component/qdrant/QdrantTestSupport.java
index ed9474fd7f5e..2ca5775ae080 100644
---
a/components/camel-ai/camel-qdrant/src/test/java/org/apache/camel/component/qdrant/QdrantTestSupport.java
+++
b/components/camel-ai/camel-qdrant/src/test/java/org/apache/camel/component/qdrant/QdrantTestSupport.java
@@ -33,8 +33,8 @@ public class QdrantTestSupport extends CamelTestSupport {
CamelContext context = super.createCamelContext();
QdrantComponent component = context.getComponent(Qdrant.SCHEME,
QdrantComponent.class);
- component.getConfiguration().setHost(QDRANT.getGrpcHost());
- component.getConfiguration().setPort(QDRANT.getGrpcPort());
+ component.getConfiguration().setHost(QDRANT.host());
+ component.getConfiguration().setPort(QDRANT.port());
component.getConfiguration().setTls(false);
return context;
